From 22c61fc3dd57e5f00b591c7453383726f6c95785 Mon Sep 17 00:00:00 2001 From: comphead Date: Tue, 7 May 2024 07:55:01 -0700 Subject: [PATCH] Fix: Sort Merge Join Left Semi crashes --- datafusion/physical-plan/src/joins/sort_merge_join.rs | 5 ----- 1 file changed, 5 deletions(-) diff --git a/datafusion/physical-plan/src/joins/sort_merge_join.rs b/datafusion/physical-plan/src/joins/sort_merge_join.rs index 81060e859b8b..3b9504f9e758 100644 --- 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 {