Fix: Sort Merge Join Left Semi crashes

comphead · May 17, 2024 · 30f28fe · 30f28fe
1 parent 22c61fc
commit 30f28fe
Showing 1 changed file with 3 additions 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
@@ -1009,7 +1009,9 @@ impl SMJStream {
                 }
                 if matches!(self.join_type, JoinType::LeftSemi) && self.filter.is_none() {
                     join_streamed = !self.streamed_joined;
-                    join_buffered = true;
+                    // if the join filter specified there can be references to buffered columns
+                    // so its needed to join them
+                    join_buffered = self.filter.is_some();
                 }
                 if matches!(
                     self.join_type,