You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/06/27 19:37:04 UTC
[jira] [Created] (FLINK-2283) Make grouped reduce/fold/aggregations
stateful using Partitioned state
Gyula Fora created FLINK-2283:
---------------------------------
Summary: Make grouped reduce/fold/aggregations stateful using Partitioned state
Key: FLINK-2283
URL: https://issues.apache.org/jira/browse/FLINK-2283
Project: Flink
Issue Type: Improvement
Components: Streaming
Affects Versions: 0.10
Reporter: Gyula Fora
Priority: Minor
Currently the inner state of the grouped aggregations are not persisted as an operator state.
These operators should be reimplemented to use the newly introduced partitioned state abstractions which will make them fault tolerant and scalable for the future.
A suggested implementation would be to use a stateful mapper to implement the desired behaviour.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)