For review

apache · Mar 18, 2024 · 938260a · 938260a
1 parent 895160b
commit 938260a
Showing 1 changed file with 2 additions and 5 deletions.
diff --git a/core/src/execution/datafusion/planner.rs b/core/src/execution/datafusion/planner.rs
@@ -916,11 +916,8 @@ impl PhysicalPlanner {
                     let full_schema = Arc::new(Schema::new(all_fields));
 
                     let physical_expr = self.create_expr(expr, full_schema)?;
-                    let (left_field_indices, right_field_indices) = expr_to_columns(
-                        &physical_expr,
-                        left.schema().fields.len(),
-                        right.schema().fields.len(),
-                    )?;
+                    let (left_field_indices, right_field_indices) =
+                        expr_to_columns(&physical_expr, left_fields.len(), right_fields.len())?;
                     let column_indices = JoinFilter::build_column_indices(
                         left_field_indices.clone(),
                         right_field_indices.clone(),