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 <fhue...@gmail.com> 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 <neoea...@gmail.com > >: > >> 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? >> >> -- >> Thanks, >> Vipul >> >
