Re: Tiemrs and restore

2018-04-16 Thread Alberto Mancini
Hi Gordon and Aljoscha, thank you. I updated the stackoverflow response too with a link to this thread to make life easier to anyone with a similar question. Thanks. A. On Mon, Apr 16, 2018 at 6:30 PM Aljoscha Krettek wrote: > Gordon is correct: there was a bug on a very old version of Flin

Re: Tiemrs and restore

2018-04-16 Thread Aljoscha Krettek
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. Aljoscha > On 16. Apr 2018, at 06:20, Tzu-Li (Gordon) Tai wrote: > > Hi Alberto, > > Looking at the code, I think the current behavior is that al

Re: Tiemrs and restore

2018-04-15 Thread Tzu-Li (Gordon) Tai
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 jo

Tiemrs and restore

2018-04-15 Thread Alberto Mancini
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