The configuration option you're looking for is `akka.ask.timeout`.
However, I'm not sure increasing this configuration would help in your case. The error message shows that there is a timeout on a local message. It is wired a local message does not get replied within 10 sec. I would suggest to look into the jobmanager logs and gc logs, see if there's any problem that prevent the process from handling the rpc messages timely. Thank you~ Xintong Song On Fri, Jul 3, 2020 at 3:51 AM M Singh <[email protected]> wrote: > Hi: > > I am using Flink 1.10 on AWS EMR cluster. > > We are getting AskTimeoutExceptions which is causing the flink jobs to > die. > > Caused by: akka.pattern.AskTimeoutException: Ask timed out on > [Actor[akka://flink/user/resourcemanager#-1602864959]] after [10000 ms]. > Message of type [org.apache.flink.runtime.rpc.messages.LocalFencedMessage]. > A typical reason for `AskTimeoutException` is that the recipient actor > didn't send a reply. > at akka.pattern.PromiseActorRef$$anonfun$2.apply(AskSupport.scala:635) > at akka.pattern.PromiseActorRef$$anonfun$2.apply(AskSupport.scala:635) > at > akka.pattern.PromiseActorRef$$anonfun$1.apply$mcV$sp(AskSupport.scala:648) > ... 9 more > > > Can you please let me know where can I set the timeout for this timeout ? > > I could not find this specific timeout in the flink doc - Apache Flink > 1.10 Documentation: Configuration > <https://ci.apache.org/projects/flink/flink-docs-stable/ops/config.html>. > > > Thanks > > Mans >
