@@ -257,6 +257,25 @@ physical_plan
25725704)------RepartitionExec: partitioning=RoundRobinBatch(4), input_partitions=1
25825805)--------DataSourceExec: file_groups={1 group: [[WORKSPACE_ROOT/datafusion/sqllogictest/test_files/scratch/dynamic_filter_pushdown_config/agg_data.parquet]]}, projection=[score], file_type=parquet, predicate=category@0 = alpha AND DynamicFilter [ empty ], pruning_predicate=category_null_count@2 != row_count@3 AND category_min@0 <= alpha AND alpha <= category_max@1, required_guarantees=[category in (alpha)]
259259
260+ # Test 4b: COUNT + MAX — DynamicFilter should NOT appear here in mixed aggregates
261+
262+ query TT
263+ EXPLAIN SELECT COUNT(*), MAX(score) FROM agg_parquet WHERE category = 'alpha';
264+ ----
265+ logical_plan
266+ 01)Projection: count(Int64(1)) AS count(*), max(agg_parquet.score)
267+ 02)--Aggregate: groupBy=[[]], aggr=[[count(Int64(1)), max(agg_parquet.score)]]
268+ 03)----Projection: agg_parquet.score
269+ 04)------Filter: agg_parquet.category = Utf8View("alpha")
270+ 05)--------TableScan: agg_parquet projection=[category, score], partial_filters=[agg_parquet.category = Utf8View("alpha")]
271+ physical_plan
272+ 01)ProjectionExec: expr=[count(Int64(1))@0 as count(*), max(agg_parquet.score)@1 as max(agg_parquet.score)]
273+ 02)--AggregateExec: mode=Final, gby=[], aggr=[count(Int64(1)), max(agg_parquet.score)]
274+ 03)----CoalescePartitionsExec
275+ 04)------AggregateExec: mode=Partial, gby=[], aggr=[count(Int64(1)), max(agg_parquet.score)]
276+ 05)--------RepartitionExec: partitioning=RoundRobinBatch(4), input_partitions=1
277+ 06)----------DataSourceExec: file_groups={1 group: [[WORKSPACE_ROOT/datafusion/sqllogictest/test_files/scratch/dynamic_filter_pushdown_config/agg_data.parquet]]}, projection=[score], file_type=parquet, predicate=category@0 = alpha, pruning_predicate=category_null_count@2 != row_count@3 AND category_min@0 <= alpha AND alpha <= category_max@1, required_guarantees=[category in (alpha)]
278+
260279# Disable aggregate dynamic filters only
261280statement ok
262281SET datafusion.optimizer.enable_aggregate_dynamic_filter_pushdown = false;
0 commit comments