flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Rahul Kavale <kavale.ra...@gmail.com>
Subject Timer fault tolerance in Flink
Date Wed, 17 May 2017 10:36:33 GMT
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

Mime
View raw message