Re: MapSate within Aggregate function

Posted by Congxian Qiu on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/MapSate-within-Aggregate-function-tp29037p29047.html

Hi Ahmad

AFAIK, Flink currently does not support stores incoming elements to a MapState, maybe the window function[1] can be help

[1] https://ci.apache.org/projects/flink/flink-docs-release-1.8/dev/stream/operators/windows.html#window-functions

Ahmad Hassan <[hidden email]> 于2019年7月25日周四 下午5:58写道：

Hi,

We have SlidingProcessingTimeWindows running with AggregateFunction and Window Function. How we use MapState within AggregateFunction to keep storing incoming elements as we receive Millions of elements over 24 running sliding windows ?

If we don't do that then AggregateFunction state grows bigger and checkpointing takes very long and fail to checkpoint frequently.

Best,