Thank you Fabian for you answer.
Best,
Yassine
On Mar 14, 2017 09:31, "Fabian Hueske" wrote:
> Hi Yassine,
>
> as far as I know, the processElement() and onTimer() methods are not
> concurrently called.
> This is definitely true for event-time timers (they are triggered by
> watermarks which ar
Hi Yassine,
as far as I know, the processElement() and onTimer() methods are not
concurrently called.
This is definitely true for event-time timers (they are triggered by
watermarks which are internally handled as records) and I'm pretty sure
that the behavior is the same for processing time timer
Hi all,
In ProcessFuction, does processElement() still get called on incoming
elements when onTimer() is called, or are elements buffered until onTimer()
returns?
I am wondering because both processElement() and onTimer() can access and
manipulate the state, so if for example state.clear() is call
