[
https://issues.apache.org/jira/browse/FLINK-22314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-22314.
---------------------------
Resolution: Invalid
> AggRecordsCombiner should combine buffered records first instead of
> accumulate on state directly
> ------------------------------------------------------------------------------------------------
>
> Key: FLINK-22314
> URL: https://issues.apache.org/jira/browse/FLINK-22314
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Runtime
> Reporter: Jark Wu
> Assignee: Jark Wu
> Priority: Major
>
> In Window TVF Aggregation, currently, the {{AggRecordsCombiner}} accumulates
> buffered records on state directly. This is not good for performance. We can
> accumulate records in memory first, and then merge the accumulator into
> state, if the aggs support {{merge()}} method. This can reduce lots of state
> accessing when having {{COUNT DISTINCT}}.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
