Hi Fabian, 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, Averell -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
