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 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 >:
>
>> 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
>>
>
