Fix: Sort Merge Join Left Semi crashes

comphead · May 17, 2024 · 22c61fc · 22c61fc
1 parent c129846
commit 22c61fc
Showing 1 changed file with 0 additions and 5 deletions.
diff --git a/datafusion/physical-plan/src/joins/sort_merge_join.rs b/datafusion/physical-plan/src/joins/sort_merge_join.rs
@@ -1023,11 +1023,6 @@ impl SMJStream {
                 if matches!(self.join_type, JoinType::Full) {
                     join_buffered = !self.buffered_joined;
                 };
-
-                if matches!(self.join_type, JoinType::LeftAnti) {
-                    join_streamed = !self.streamed_joined;
-                    join_buffered = true;
-                };
             }
         }
         if !join_streamed && !join_buffered {