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 >> > >
