qiuyanjun888 opened a new pull request, #28370: URL: https://github.com/apache/flink/pull/28370
## What is the purpose of the change Fix nested projection pushdown when a filter cannot be pushed into the table source. The project rewrite phase now keeps complete filter expressions while transposing project/filter, so nested fields referenced only by the non-pushable filter are not pruned away from the source projection. ## Brief change log - Add separate batch/stream project rewrite rule sets that use `PROJECT_FILTER_TRANSPOSE_WHOLE_EXPRESSIONS`. - Use the rewrite-specific project rules in the batch and stream project rewrite programs. - Add batch and stream SQL plan regression coverage for nested projection with a non-pushable filter. ## Verifying this change - `./mvnw -pl flink-table/flink-table-planner -Dtest='org.apache.flink.table.planner.plan.stream.sql.TableSourceTest,org.apache.flink.table.planner.plan.batch.sql.TableSourceTest' -DfailIfNoTests=false -Dsurefire.failIfNoSpecifiedTests=false -DskipITs -Dfast test` - `./mvnw -pl flink-table/flink-table-planner spotless:check -DskipITs` - `git diff --check` -- 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]
