Hi Rahul,
The timers are fault tolerant and their timestamp is the absolute value of when
to fire.
This means that if you are at time t = 10 and you register a timer “10 ms from
now”, the timer will have a firing timestamp of 20.
This is checkpointed, so the “new machine” that takes over the fai
I am looking at timers in apache flink and wanted to confirm if the timers
in flink are fault tolerant.
eg. when a timer registered with processFunction, of say 20 sec is running
on a node and after 15 seconds (since the timer started), the node failed
for some reason. Does flink guarantee that th