From dc8ad8a8bda7ceb2f02335317b79f1249625f00c Mon Sep 17 00:00:00 2001
From: comphead <comphead@ukr.net>
Date: Thu, 20 Jun 2024 19:14:59 -0700
Subject: [PATCH] SMJ: fix streaming row concurrency issue for LEFT SEMI
 filtered join

---
 datafusion/physical-plan/src/joins/sort_merge_join.rs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/datafusion/physical-plan/src/joins/sort_merge_join.rs b/datafusion/physical-plan/src/joins/sort_merge_join.rs
index 9f7a38aa2e29..91b2151d32e7 100644
--- 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,