Re: delete all available flink timers on app start

2019-01-17 Thread 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, 201

Re: delete all available flink timers on app start

2019-01-17 Thread Fabian Hueske
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 don

delete all available flink timers on app start

2019-01-16 Thread 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