SMJ: fix streaming row concurrency issue for LEFT SEMI filtered join

comphead · Jun 21, 2024 · dc8ad8a · dc8ad8a
1 parent 64f0b3d
commit dc8ad8a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/datafusion/physical-plan/src/joins/sort_merge_join.rs b/datafusion/physical-plan/src/joins/sort_merge_join.rs
@@ -2947,7 +2947,7 @@ mod tests {
         assert_eq!(
             get_filtered_join_mask(
                 LeftSemi,
-                UInt64Array::from(vec![0, 0, 0, 1, 1, 1]),
+                &UInt64Array::from(vec![0, 0, 0, 1, 1, 1]),
                 &BooleanArray::from(vec![true, false, false, false, false, true]),
                 &HashSet::from_iter(vec![1]),
                 &0,