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)