Thanks for the suggestion.
I will try with that support of removing timers.
I have also tried approach (3) - using session windows, and it works: I set
session gap to 2 minutes, and use an aggregation window function to keep the
amount of in-memory data for each keyed stream to the minimum level.
Could you please explain why (2) is better?
Thanks and best regards,
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/