Re: Akka heartbeat configurations

2018-05-16 Thread Bajaj, Abhinav
I had the same feeling. Thanks Timo for clarifying. ~ Abhinav From: Timo Walther Date: Tuesday, May 15, 2018 at 6:05 AM To: "user@flink.apache.org" Subject: Re: Akka heartbeat configurations Hi, increasing the time to detect a dead task manager usually increases the amount of ele

Re: Akka heartbeat configurations

2018-05-15 Thread Timo Walther
Hi, increasing the time to detect a dead task manager usually increases the amount of elements that need to be reprocessed in case of a failure. Once a dead task manager is identified, the entire application is rolled back to the latest successful checkpointed/consistent state of the applicat

Akka heartbeat configurations

2018-05-14 Thread Bajaj, Abhinav
Hi, We are running into issues where GC pause will result into Taskmanagers being marked dead incorrectly. Flink documentation documents some knobs of Akka configurations to play aroun