Hi! Yes, the processing time timers are persisted in the checkpoint and restored on recovery. If a timer is in the past, it should fire immediately after recovery.
I think there may be a bug in the 1.1 branch that requires at least one more time to be registered before the restored timers fire. 1.2 should behave well. The issue for the bug: https://issues.apache.org/jira/browse/FLINK-4651 + Aljoscha and Kostas - for more details Best, Stephan On Thu, Dec 29, 2016 at 10:36 PM, Scott Kidder <kidder.sc...@gmail.com> wrote: > Are processing-time timers retained in checkpoint & savepoint state and > run if a job is restarted? It's possible that the time at which timer was > intended to trigger at passes while the job is in the middle of being > restarted. Are processing-time timers persisted at all? > > Thanks! > > --Scott Kidder >
