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 the timer resume on another
node? if it does resume does it consider only the remaining time for the
timer ie 5 sec in this case?

Thanks & Regards,

Rahul

Reply via email to