You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Aitozi (Jira)" <ji...@apache.org> on 2022/11/30 06:19:00 UTC

[jira] [Created] (FLINK-30242) Push localHashAggregate pass the union node

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)