mikamikasuki opened a new pull request, #26056: URL: https://github.com/apache/datafusion/pull/26056
## Which issue does this PR close? Closes #26054 ## Rationale for this change In a recursive CTE, an uncorrelated MIN/MAX over a Parquet table returns the correct value on the first iteration but NULL or an incorrect value on later iterations because the aggregate reuses the dynamic filter tightened during the first scan. ## What changes are included in this PR? Reset AggregateExec's dynamic filter expression and shared accumulator bounds when the plan is reused, allowing each recursive iteration to scan with fresh bounds. ## What is the testing strategy for this PR? Added a cte.slt regression for the reported recursive MAX query. Validation passed: `cargo test -p datafusion-sqllogictest --test sqllogictests -- cte.slt`; `cargo test -p datafusion-physical-plan --lib` (2,441 passed); `cargo test -p datafusion-physical-expr --lib` (1,686 passed, 2 ignored); `cargo fmt --all -- --check`; and targeted Clippy with `-A clippy::ignore_without_reason -D warnings`. The unsuppressed Rust 1.99 Clippy run reports the existing `ignore_without_reason` lint in `datafusion/physical-expr/src/planner.rs`. ## Are there any user-facing changes? Recursive CTE iterations now return the correct aggregate result consistently while retaining dynamic-filter pruning. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
