Skip to content

Commit 50e9973

Browse files
committed
fix DynamicFilterPhysicalExpr test
1 parent 9fdb7b3 commit 50e9973

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

  • datafusion/core/tests/physical_optimizer/filter_pushdown

datafusion/core/tests/physical_optimizer/filter_pushdown/mod.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -906,7 +906,7 @@ async fn test_topk_filter_passes_through_coalesce_partitions() {
906906
Ok:
907907
- SortExec: TopK(fetch=1), expr=[b@1 DESC NULLS LAST], preserve_partitioning=[false]
908908
- CoalescePartitionsExec
909-
- DataSourceExec: file_groups={2 groups: [[test1.parquet], [test2.parquet]]}, projection=[a, b, c], file_type=test, pushdown_supported=true, predicate=DynamicFilter [ empty ]
909+
- DataSourceExec: file_groups={2 groups: [[test1.parquet], [test2.parquet]]}, projection=[a, b, c], file_type=test, pushdown_supported=true, predicate=DynamicFilterPhysicalExpr [ true ]
910910
"
911911
);
912912
}
@@ -961,7 +961,7 @@ async fn test_topk_filter_passes_through_coalesce_batches() {
961961
Ok:
962962
- SortExec: TopK(fetch=1), expr=[b@1 DESC NULLS LAST], preserve_partitioning=[false]
963963
- CoalesceBatchesExec: target_batch_size=1024
964-
- DataSourceExec: file_groups={1 group: [[test.parquet]]}, projection=[a, b, c], file_type=test, pushdown_supported=true, predicate=DynamicFilter [ empty ]
964+
- DataSourceExec: file_groups={1 group: [[test.parquet]]}, projection=[a, b, c], file_type=test, pushdown_supported=true, predicate=DynamicFilterPhysicalExpr [ true ]
965965
"
966966
);
967967
}

0 commit comments

Comments
 (0)