flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Scott Kidder <kidder.sc...@gmail.com>
Subject Re: Processing-Time Timers and Checkpoint State
Date Fri, 30 Dec 2016 18:04:46 GMT
Excellent, thank you Stephan!

On Fri, Dec 30, 2016 at 6:58 AM, Stephan Ewen <sewen@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.scott@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
>>
>
>

Mime
View raw message