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

Posted to issues@flink.apache.org by "Q Kang (Jira)" <ji...@apache.org> on 2022/01/11 15:22:00 UTC

[jira] [Created] (FLINK-25614) Let LocalWindowAggregate be chained with upstream

Q Kang created FLINK-25614:
------------------------------

             Summary: Let LocalWindowAggregate be chained with upstream
                 Key: FLINK-25614
                 URL: https://issues.apache.org/jira/browse/FLINK-25614
             Project: Flink
          Issue Type: Improvement
          Components: Table SQL / Runtime
    Affects Versions: 1.14.2
            Reporter: Q Kang


When enabling two-phase aggregation (local-global) strategy for Window TVF, the physical plan is shown as follows:
{code:java}
TableSourceScan -> Calc -> WatermarkAssigner -> Calc
||
|| [FORWARD]
||
LocalWindowAggregate
||
|| [HASH]
||
GlobalWindowAggregate
||
||
...{code}
We can let the `LocalWindowAggregate` node be chained with upstream operators in order to improve efficiency, just like the non-windowing counterpart `LocalGroupAggregate`.

 



--
This message was sent by Atlassian Jira
(v8.20.1#820001)