delete all available flink timers on app start

[vipul singh]

Hello,

I have a custom app, in which when due to some exception, the app restarts I want to cancel all registered flink timers in the initializeState method. Based on the documentation I feel like all timer state is saved in the state, so if the app restarts the timers are still active. 

Is there a way to delete all available timers on app crash and restart?

--

[Fabian Hueske-2]

Hi Vipul,

I'm not aware of a way to do this.

You could have a list of all registered timers per key as state to be able to delete them.

However, the problem is to identify in user code when an application was restarted, i.e., to know when to delete timers.

Also, timer deletion would need to be done per key.

Best,

Fabian

Am Do., 17. Jan. 2019 um 08:27 Uhr schrieb vipul singh <[hidden email]>:

Hello,

I have a custom app, in which when due to some exception, the app restarts I want to cancel all registered flink timers in the initializeState method. Based on the documentation I feel like all timer state is saved in the state, so if the app restarts the timers are still active. 

Is there a way to delete all available timers on app crash and restart?

--

[Steven Wu]

Vipul, 

it sounds like you don't want to checkpoint timer at all. since 1.7, we can configure timer state backend (HEAP/ROCKSDB). I guess a new option (NONE) can be added to support such requirement.

but it is interesting to see your reasons. can you elaborate?

thanks,

Steven

On Thu, Jan 17, 2019 at 5:53 AM Fabian Hueske <[hidden email]> wrote:

Hi Vipul,

I'm not aware of a way to do this.

You could have a list of all registered timers per key as state to be able to delete them.

However, the problem is to identify in user code when an application was restarted, i.e., to know when to delete timers.

Also, timer deletion would need to be done per key.

Best,

Fabian

Am Do., 17. Jan. 2019 um 08:27 Uhr schrieb vipul singh <[hidden email]>:

Hello,

I have a custom app, in which when due to some exception, the app restarts I want to cancel all registered flink timers in the initializeState method. Based on the documentation I feel like all timer state is saved in the state, so if the app restarts the timers are still active. 

Is there a way to delete all available timers on app crash and restart?

--