Move filtered SMJ Full filtered join out of join_partial phase

comphead · Nov 12, 2024 · afd8a41 · afd8a41
1 parent 13815ad
commit afd8a41
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/datafusion/physical-plan/src/joins/sort_merge_join.rs b/datafusion/physical-plan/src/joins/sort_merge_join.rs
@@ -1763,14 +1763,14 @@ impl SMJStream {
         let mut out_indices = self.output_record_batches.row_indices.finish();
         let mut out_mask = self.output_record_batches.filter_mask.finish();
         let mut batch_ids = &self.output_record_batches.batch_ids;
-        let x = vec![0; record_batch.num_rows()];
+        let default_batch_ids = vec![0; record_batch.num_rows()];
 
         if out_indices.null_count() == out_indices.len()
             && out_indices.len() != record_batch.num_rows()
         {
             out_mask = BooleanArray::from(vec![None; record_batch.num_rows()]);
             out_indices = UInt64Array::from(vec![None; record_batch.num_rows()]);
-            batch_ids = &x;
+            batch_ids = &default_batch_ids;
         }
 
         if out_mask.is_empty() {