Details
-
Improvement
-
Status: Closed
-
Major
-
Resolution: Duplicate
-
1.5.0
-
None
-
None
-
- FLIP-6 enabled
- Local Flink instance with fixed number of TMs
- Job parallelism exceeds available slots
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)
Attachments
Issue Links
- duplicates
-
FLINK-10883 Submitting a jobs without enough slots times out due to a unspecified timeout
- Resolved
- links to