MapSate within Aggregate function

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

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,