[FLINK-9056] Job submission fails with AskTimeoutException if not enough slots are available

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Duplicate
• Affects Version/s: 1.5.0
• Component/s: Runtime / Coordination

Environment

• FLIP-6 enabled
• Local Flink instance with fixed number of TMs
• Job parallelism exceeds available slots

• Assignee: yuqi
• Reporter: Fabian Hueske
• Created: 22/Mar/18 15:17
• Updated: 28/Feb/19 13:30
• Resolved: 19/Nov/18 08:15

Description

The error message if a job submission fails due to lack of available slots is not helpful:

Caused by: akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka://flink/user/8f0fabba-4021-45b6-a1f7-b8afd6627640#-574617182|#-574617182]] after [300000 ms]. Sender[null] sent message of type "org.apache.flink.runtime.rpc.messages.LocalRpcInvocation".
     at akka.pattern.PromiseActorRef$$anonfun$1.apply$mcV$sp(AskSupport.scala:604)
     at akka.actor.Scheduler$$anon$4.run(Scheduler.scala:126)
     at scala.concurrent.Future$InternalCallbackExecutor$.unbatchedExecute(Future.scala:601)
     at scala.concurrent.BatchingExecutor$class.execute(BatchingExecutor.scala:109)
     at scala.concurrent.Future$InternalCallbackExecutor$.execute(Future.scala:599)
     at akka.actor.LightArrayRevolverScheduler$TaskHolder.executeTask(LightArrayRevolverScheduler.scala:329)
     at akka.actor.LightArrayRevolverScheduler$$anon$4.executeBucket$1(LightArrayRevolverScheduler.scala:280)
     at akka.actor.LightArrayRevolverScheduler$$anon$4.nextTick(LightArrayRevolverScheduler.scala:284)
     at akka.actor.LightArrayRevolverScheduler$$anon$4.run(LightArrayRevolverScheduler.scala:236)
     at java.lang.Thread.run(Thread.java:748)

Issue Links

• duplicates: FLINK-10883 Submitting a jobs without enough slots times out due to a unspecified timeout
• links to: GitHub Pull Request #5829
• links to: GitHub Pull Request #5829