[
https://issues.apache.org/jira/browse/FLINK-989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14058680#comment-14058680
]
Stephan Ewen commented on FLINK-989:
------------------------------------
Slight edit:
"Not enough available task slots to run job " + jobName "(" jobId + ").
Required: " + requiredSlots + " Available: " + availableSlots + ". Either
reduce the parallelism of your program, wait for other programs to finish, or
increase the number of task slots in the cluster by adding more machines or
increasing the number of slots per machine in conf/flink-conf.yaml .");
> Improve not enough slots SchedulingException message
> ----------------------------------------------------
>
> Key: FLINK-989
> URL: https://issues.apache.org/jira/browse/FLINK-989
> Project: Flink
> Issue Type: Bug
> Components: JobManager
> Reporter: Ufuk Celebi
> Priority: Critical
>
> I think it would be good to have a more detailed message for the following
> SchedulingException (available slots, required slots etc.):
> {code:java}
> eu.stratosphere.client.program.ProgramInvocationException: The program
> execution failed:
> eu.stratosphere.nephele.jobmanager.scheduler.SchedulingException: Not enough
> slots to schedule job 04d754249c6c580000cd461d195ca000
> at
> eu.stratosphere.nephele.jobmanager.scheduler.DefaultScheduler.scheduleJob(DefaultScheduler.java:150)
> at
> eu.stratosphere.nephele.jobmanager.JobManager.submitJob(JobManager.java:504)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
> at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.lang.reflect.Method.invoke(Method.java:606)
> at eu.stratosphere.nephele.ipc.RPC$Server.call(RPC.java:417)
> at eu.stratosphere.nephele.ipc.Server$Handler.run(Server.java:951)
> {code}
--
This message was sent by Atlassian JIRA
(v6.2#6252)
