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)