Skip to content

Commit f6934d1

Browse files
committed
fix ci
1 parent 93829ee commit f6934d1

File tree

1 file changed

+5
-6
lines changed

1 file changed

+5
-6
lines changed

datafusion/sqllogictest/test_files/on_demand_repartition.slt

Lines changed: 5 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -230,12 +230,11 @@ logical_plan
230230
02)--Filter: sink_table.c3 > Int16(0)
231231
03)----TableScan: sink_table projection=[c1, c2, c3]
232232
physical_plan
233-
01)GlobalLimitExec: skip=0, fetch=5
234-
02)--CoalescePartitionsExec
235-
03)----CoalesceBatchesExec: target_batch_size=8192, fetch=5
236-
04)------FilterExec: c3@2 > 0
237-
05)--------OnDemandRepartitionExec: partitioning=OnDemand(3), input_partitions=1
238-
06)----------StreamingTableExec: partition_sizes=1, projection=[c1, c2, c3], infinite_source=true
233+
01)CoalescePartitionsExec: fetch=5
234+
02)--CoalesceBatchesExec: target_batch_size=8192, fetch=5
235+
03)----FilterExec: c3@2 > 0
236+
04)------OnDemandRepartitionExec: partitioning=OnDemand(3), input_partitions=1
237+
05)--------StreamingTableExec: partition_sizes=1, projection=[c1, c2, c3], infinite_source=true
239238

240239
# Start repratition on empty column test.
241240
# See https://github.com/apache/datafusion/issues/12057

0 commit comments

Comments
 (0)