flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Aljoscha Krettek <aljos...@apache.org>
Subject Re: Tiemrs and restore
Date Mon, 16 Apr 2018 16:30:48 GMT
Gordon is correct: there was a bug on a very old version of Flink that caused processing-timers
not to be invoked after restore but that was fixed.


> On 16. Apr 2018, at 06:20, Tzu-Li (Gordon) Tai <tzulitai@apache.org> wrote:
> Hi Alberto,
> Looking at the code, I think the current behavior is that all timers (both processing
time and event time) are re-registered on restore, and therefore should be triggered automatically.
> So, for processing time timers, on restore all timers that were supposed to be fired
while the job was down should fire automatically; for event time timers, they will be triggered
once the watermark passes their timestamps.
> Also looped in Aljoscha on this, in case I misunderstood anything.
> Cheers,
> Gordon
> On 16 April 2018 at 1:20:00 AM, Alberto Mancini (ab.mancini@gmail.com <mailto:ab.mancini@gmail.com>)
>> Hello,
>> according to this stackoverflow response 
>> https://stackoverflow.com/questions/36306136/will-apache-flink-restore-trigger-timers-after-failure
>> IIUC we should expect that after a restore the timers will be not executed until
a new timer is scheduled. 
>> I wonder if this is still true and if there is any chance of forcing the restart
of the timer task.
>> Thank you. 
>> Regards,
>>    Alberto. 

View raw message