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,
