Re: Timer fault tolerance in Flink

2017-05-17 Thread Kostas Kloudas
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

Timer fault tolerance in Flink

2017-05-17 Thread Rahul Kavale
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