I'd go with 2) because the logic is simple and it is (IMO) much easier to understand what is going on and what state is kept.
Am Do., 11. Okt. 2018 um 12:42 Uhr schrieb Averell <lvhu...@gmail.com>: > 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/ >
