[FLINK-3964] add hint to job submission timeout exception message This closes #2168
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0e8be413 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0e8be413 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/0e8be413 Branch: refs/heads/master Commit: 0e8be4134f10cbe8aa91602b0ebf28d4b674ff36 Parents: 8d58962 Author: Maximilian Michels <[email protected]> Authored: Mon Jun 27 12:30:12 2016 +0200 Committer: Maximilian Michels <[email protected]> Committed: Fri Jul 1 15:22:31 2016 +0200 ---------------------------------------------------------------------- .../java/org/apache/flink/runtime/client/JobClientActor.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/0e8be413/flink-runtime/src/main/java/org/apache/flink/runtime/client/JobClientActor.java ---------------------------------------------------------------------- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/client/JobClientActor.java b/flink-runtime/src/main/java/org/apache/flink/runtime/client/JobClientActor.java index f2a2e1b..e51946f 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/client/JobClientActor.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/client/JobClientActor.java @@ -25,6 +25,7 @@ import akka.actor.Status; import akka.actor.Terminated; import akka.dispatch.Futures; import akka.dispatch.OnSuccess; +import org.apache.flink.configuration.ConfigConstants; import org.apache.flink.runtime.akka.AkkaUtils; import org.apache.flink.runtime.akka.FlinkUntypedActor; import org.apache.flink.runtime.akka.ListeningBehaviour; @@ -255,7 +256,9 @@ public class JobClientActor extends FlinkUntypedActor implements LeaderRetrieval if (hasJobBeenSubmitted()) { submitter.tell( decorateMessage(new Status.Failure( - new JobClientActorSubmissionTimeoutException("Job submission to the JobManager timed out."))), + new JobClientActorSubmissionTimeoutException("Job submission to the JobManager timed out. " + + "You may increase '" + ConfigConstants.AKKA_CLIENT_TIMEOUT + "' in case the JobManager " + + "needs more time to configure and confirm the job submission."))), getSelf()); }
