Re: A question about Triggers

2017-12-23 Thread Fabian Hueske
Hi, all calls to onElement() or onTimer() are syncronized for any keys. Think of a single thread calling these methods. Event-time timers are called when a watermark passes the timer. Watermarks are received as special records, so the methods are called in the same order as records (actual records

Re: A question about Triggers

2017-12-23 Thread Vishal Santoshi
Thanks. I have a few follow up questions regarding ProcessFunction. I think that the core should take care of any synchronization issues between calls to onElement and onTimer in case of a keyed stream but tests do not seem to suggest that. I have specifically 2 questions. 1. Are cal