Aitozi created FLINK-30242:
------------------------------
Summary: Push localHashAggregate pass the union node
Key: FLINK-30242
URL: https://issues.apache.org/jira/browse/FLINK-30242
Project: Flink
Issue Type: Improvement
Components: Table SQL / Planner
Reporter: Aitozi
The local hash aggregate after union will have an extra shuffle stage. We can
swap it with the union node so the local hash aggregate can chain with the
mapper stage saving the unnecessary shuffle, especially in the batch job.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
