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 called at the end
of onTimer() is there a risk that a state update by processElement() that
happened during the onTimer() call get cleared? Thank you in advance.

Best,
Yassine

Reply via email to