[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Re: Identifying missing events in keyed streams

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 <lvhuyen@xxxxxxxxx>:
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,

Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/