I forgot to say that timers are fault-tolerant. You set them, and Flink takes
care of checkpointing and
restoring them after failure. The flag will also be fault-tolerant as, i
suppose, you will use Flink’s keyed state.
For more info, you can check the ProcessFunction documentation that
Hi Ryan,
“A periodic window like this requires the ability to start a timer without an
element and to restart a timer when fired.”
For the second part, i.e. “to restart a timer when fired”, you can re-register
the timer in the onTimer() method (set a
new timer for “now + T"), so that the next
