Skip to content

Commit dc21d53

Browse files
committed
chore: Modify the output consistency
Signed-off-by: Alan Tang <[email protected]>
1 parent 068f53c commit dc21d53

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

datafusion/core/tests/physical_optimizer/limit_pushdown.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -234,7 +234,7 @@ fn transforms_coalesce_batches_exec_into_fetching_version_and_removes_local_limi
234234

235235
let expected = [
236236
"CoalescePartitionsExec: fetch=5",
237-
" CoalesceBatchesExec: target_batch_size=8192, fetch=5",
237+
" CoalesceBatchesExec: target_batch_size=8192, limit=5",
238238
" FilterExec: c3@2 > 0",
239239
" RepartitionExec: partitioning=RoundRobinBatch(8), input_partitions=1",
240240
" StreamingTableExec: partition_sizes=1, projection=[c1, c2, c3], infinite_source=true"
@@ -299,7 +299,7 @@ fn pushes_global_limit_exec_through_projection_exec_and_transforms_coalesce_batc
299299

300300
let expected = [
301301
"ProjectionExec: expr=[c1@0 as c1, c2@1 as c2, c3@2 as c3]",
302-
" CoalesceBatchesExec: target_batch_size=8192, fetch=5",
302+
" CoalesceBatchesExec: target_batch_size=8192, limit=5",
303303
" StreamingTableExec: partition_sizes=1, projection=[c1, c2, c3], infinite_source=true"
304304
];
305305
assert_eq!(get_plan_string(&after_optimize), expected);

0 commit comments

Comments
 (0)