File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
datafusion/physical-plan/src/joins Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -1105,7 +1105,7 @@ impl ExecutionPlan for HashJoinExec {
11051105 assert_eq ! ( child_pushdown_result. self_filters. len( ) , 2 ) ; // Should always be 2, we have 2 children
11061106 let right_child_self_filters = & child_pushdown_result. self_filters [ 1 ] ; // We only push down filters to the right child
11071107 // We expect 0 or 1 self filters
1108- if let Some ( filter) = right_child_self_filters. get ( 0 ) {
1108+ if let Some ( filter) = right_child_self_filters. first ( ) {
11091109 // Note that we don't check PushdDownPredicate::discrimnant because even if nothing said
11101110 // "yes, I can fully evaluate this filter" things might still use it for statistics -> it's worth updating
11111111 let predicate = Arc :: clone ( & filter. predicate ) ;
@@ -1120,7 +1120,7 @@ impl ExecutionPlan for HashJoinExec {
11201120 filter : self . filter . clone ( ) ,
11211121 join_type : self . join_type ,
11221122 join_schema : Arc :: clone ( & self . join_schema ) ,
1123- left_fut : self . left_fut . clone ( ) ,
1123+ left_fut : Arc :: clone ( & self . left_fut ) ,
11241124 random_state : self . random_state . clone ( ) ,
11251125 mode : self . mode ,
11261126 metrics : ExecutionPlanMetricsSet :: new ( ) ,
You can’t perform that action at this time.
0 commit comments