I just verified that this does indeed work on master and the Flink 1.2 branch. I'm also pushing a test that verifies this.
Stephan is right that this doesn't work on Flink 1.1? Is that critical for you, if yes, then we should think about pushing out another Flink 1.x bugfix release. Cheers, Aljoscha On Fri, 30 Dec 2016 at 19:05 Scott Kidder <kidder.sc...@gmail.com> wrote: > Excellent, thank you Stephan! > > On Fri, Dec 30, 2016 at 6:58 AM, Stephan Ewen <se...@apache.org> wrote: > > 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 > > > >
