[jira] [Closed] (FLINK-3473) Add partial aggregate support in Flink

["Timo Walther (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-3473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Timo Walther closed FLINK-3473.
-------------------------------
    Resolution: Won't Fix

Many of these ideas have been implemented in the new planner. Since the old planner has been remove, I will close this issue now. Please reopen if you think that this topic has not been addressed.

> Add partial aggregate support in Flink
> --------------------------------------
>
>                 Key: FLINK-3473
>                 URL: https://issues.apache.org/jira/browse/FLINK-3473
>             Project: Flink
>          Issue Type: Improvement
>          Components: Table SQL / Legacy Planner
>            Reporter: Chengxiang Li
>            Priority: Minor
>              Labels: auto-deprioritized-major, auto-unassigned
>         Attachments: PartialAggregateinFlink_v1.pdf, PartialAggregateinFlink_v2.pdf
>
>
> For decomposable aggregate function, partial aggregate is more efficient as it significantly reduce the network traffic during shuffle and parallelize part of the aggregate calculation. This is an umbrella task for partial aggregate.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)