flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Yassine MARZOUGUI <y.marzou...@mindlytix.com>
Subject Question about processElement(...) and onTimer(...) in ProcessFunction
Date Tue, 14 Mar 2017 07:04:20 GMT
Hi all,

In ProcessFuction, does processElement() still get called on incoming
elements when onTimer() is called, or are elements buffered until onTimer()
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.


View raw message