[FLINK-18441] support Local-Global Aggregation with LastValue Funciton

• Type: Improvement
• Status: Open
• Priority: Not a Priority
• Resolution: Unresolved
• Component/s: Table SQL / Planner
• Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available
• Assignee: Unassigned
• Reporter: wangpeibin
• Due: 01/Sep/20
• Created: 28/Jun/20 07:50
• Updated: 16/Apr/22 22:38

Description

The optimization of Local-Global Aggregation is invalid when the last_value aggregation function exists,  such as 

select k, sum(v) as v, last_value(v) as last_v
 from a
 group by k

right now  the ExecutionPlan is: 

but with the  optimization of Local-Global Aggregation enabled, the ExecutionPlan is supported to be：

 

 

Issue Links

• links to: GitHub Pull Request #12780