Skip to content

Commit 4e9f319

Browse files
committed
test: enable aggregate filter pushdown regressions
1 parent 4b0e6c6 commit 4e9f319

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

datafusion/core/tests/physical_optimizer/filter_pushdown.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1818,9 +1818,9 @@ fn col_lit_predicate(
18181818
}
18191819

18201820
fn assert_parent_filter_remains_above_aggregate(plan: Arc<dyn ExecutionPlan>) {
1821-
let optimized = FilterPushdown::new()
1822-
.optimize(plan, &ConfigOptions::default())
1823-
.unwrap();
1821+
let mut config = ConfigOptions::default();
1822+
config.execution.parquet.pushdown_filters = true;
1823+
let optimized = FilterPushdown::new().optimize(plan, &config).unwrap();
18241824
assert!(
18251825
optimized.downcast_ref::<FilterExec>().is_some(),
18261826
"parent filter must remain above aggregate"

0 commit comments

Comments
 (0)