Skip to content

Commit dbc03fa

Browse files
authored
fix another flaky join test (#16880)
1 parent 51f04c8 commit dbc03fa

File tree

1 file changed

+10
-10
lines changed

1 file changed

+10
-10
lines changed

datafusion/sqllogictest/test_files/joins.slt

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -4260,23 +4260,23 @@ set datafusion.execution.target_partitions = 1;
42604260
# Note we use csv as MemoryExec does not support limit push down (so doesn't manifest
42614261
# bugs if limits are improperly pushed down)
42624262
query I
4263-
COPY (values (1), (2), (3), (4), (5)) TO 'test_files/scratch/limit/t1.csv'
4263+
COPY (values (1), (2), (3), (4), (5)) TO 'test_files/scratch/joins/t1.csv'
42644264
STORED AS CSV
42654265
----
42664266
5
42674267

42684268
# store t2 in different order so the top N rows are not the same as the top N rows of t1
42694269
query I
4270-
COPY (values (5), (4), (3), (2), (1)) TO 'test_files/scratch/limit/t2.csv'
4270+
COPY (values (5), (4), (3), (2), (1)) TO 'test_files/scratch/joins/t2.csv'
42714271
STORED AS CSV
42724272
----
42734273
5
42744274

42754275
statement ok
4276-
create external table t1(a int) stored as CSV location 'test_files/scratch/limit/t1.csv';
4276+
create external table t1(a int) stored as CSV location 'test_files/scratch/joins/t1.csv';
42774277

42784278
statement ok
4279-
create external table t2(b int) stored as CSV location 'test_files/scratch/limit/t2.csv';
4279+
create external table t2(b int) stored as CSV location 'test_files/scratch/joins/t2.csv';
42804280

42814281
######
42824282
## LEFT JOIN w/ LIMIT
@@ -4308,8 +4308,8 @@ logical_plan
43084308
physical_plan
43094309
01)CoalesceBatchesExec: target_batch_size=3, fetch=2
43104310
02)--HashJoinExec: mode=CollectLeft, join_type=Left, on=[(a@0, b@0)]
4311-
03)----DataSourceExec: file_groups={1 group: [[WORKSPACE_ROOT/datafusion/sqllogictest/test_files/scratch/limit/t1.csv]]}, projection=[a], limit=2, file_type=csv, has_header=true
4312-
04)----DataSourceExec: file_groups={1 group: [[WORKSPACE_ROOT/datafusion/sqllogictest/test_files/scratch/limit/t2.csv]]}, projection=[b], file_type=csv, has_header=true
4311+
03)----DataSourceExec: file_groups={1 group: [[WORKSPACE_ROOT/datafusion/sqllogictest/test_files/scratch/joins/t1.csv]]}, projection=[a], limit=2, file_type=csv, has_header=true
4312+
04)----DataSourceExec: file_groups={1 group: [[WORKSPACE_ROOT/datafusion/sqllogictest/test_files/scratch/joins/t2.csv]]}, projection=[b], file_type=csv, has_header=true
43134313

43144314
######
43154315
## RIGHT JOIN w/ LIMIT
@@ -4342,8 +4342,8 @@ logical_plan
43424342
physical_plan
43434343
01)CoalesceBatchesExec: target_batch_size=3, fetch=2
43444344
02)--HashJoinExec: mode=CollectLeft, join_type=Right, on=[(a@0, b@0)]
4345-
03)----DataSourceExec: file_groups={1 group: [[WORKSPACE_ROOT/datafusion/sqllogictest/test_files/scratch/limit/t1.csv]]}, projection=[a], file_type=csv, has_header=true
4346-
04)----DataSourceExec: file_groups={1 group: [[WORKSPACE_ROOT/datafusion/sqllogictest/test_files/scratch/limit/t2.csv]]}, projection=[b], limit=2, file_type=csv, has_header=true
4345+
03)----DataSourceExec: file_groups={1 group: [[WORKSPACE_ROOT/datafusion/sqllogictest/test_files/scratch/joins/t1.csv]]}, projection=[a], file_type=csv, has_header=true
4346+
04)----DataSourceExec: file_groups={1 group: [[WORKSPACE_ROOT/datafusion/sqllogictest/test_files/scratch/joins/t2.csv]]}, projection=[b], limit=2, file_type=csv, has_header=true
43474347

43484348
######
43494349
## FULL JOIN w/ LIMIT
@@ -4379,8 +4379,8 @@ logical_plan
43794379
physical_plan
43804380
01)CoalesceBatchesExec: target_batch_size=3, fetch=2
43814381
02)--HashJoinExec: mode=CollectLeft, join_type=Full, on=[(a@0, b@0)]
4382-
03)----DataSourceExec: file_groups={1 group: [[WORKSPACE_ROOT/datafusion/sqllogictest/test_files/scratch/limit/t1.csv]]}, projection=[a], file_type=csv, has_header=true
4383-
04)----DataSourceExec: file_groups={1 group: [[WORKSPACE_ROOT/datafusion/sqllogictest/test_files/scratch/limit/t2.csv]]}, projection=[b], file_type=csv, has_header=true
4382+
03)----DataSourceExec: file_groups={1 group: [[WORKSPACE_ROOT/datafusion/sqllogictest/test_files/scratch/joins/t1.csv]]}, projection=[a], file_type=csv, has_header=true
4383+
04)----DataSourceExec: file_groups={1 group: [[WORKSPACE_ROOT/datafusion/sqllogictest/test_files/scratch/joins/t2.csv]]}, projection=[b], file_type=csv, has_header=true
43844384

43854385
statement ok
43864386
drop table t1;

0 commit comments

Comments
 (0)