Skip to content

Commit c960bda

Browse files
committed
Fix filter application order in RightAnti join execution plan
1 parent 15c8897 commit c960bda

File tree

1 file changed

+6
-4
lines changed

1 file changed

+6
-4
lines changed

datafusion/sqllogictest/test_files/joins.slt

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -5127,10 +5127,12 @@ WHERE k1 < 0
51275127
physical_plan
51285128
01)CoalesceBatchesExec: target_batch_size=3
51295129
02)--HashJoinExec: mode=CollectLeft, join_type=RightAnti, on=[(k2@0, k1@0)]
5130-
03)----DataSourceExec: partitions=1, partition_sizes=[0]
5131-
04)----CoalesceBatchesExec: target_batch_size=3
5132-
05)------FilterExec: k1@0 < 0
5133-
06)--------DataSourceExec: partitions=1, partition_sizes=[10000]
5130+
03)----CoalesceBatchesExec: target_batch_size=3
5131+
04)------FilterExec: k2@0 < 0
5132+
05)--------DataSourceExec: partitions=1, partition_sizes=[0]
5133+
06)----CoalesceBatchesExec: target_batch_size=3
5134+
07)------FilterExec: k1@0 < 0
5135+
08)--------DataSourceExec: partitions=1, partition_sizes=[10000]
51345136

51355137
query II
51365138
SELECT *

0 commit comments

Comments
 (0)