[FLINK-3667] print JobID on submission
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a3aea279 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a3aea279 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a3aea279 Branch: refs/heads/master Commit: a3aea27983d23d48bbad92c400d4cd42f36fabd3 Parents: 44b3bc4 Author: Maximilian Michels <[email protected]> Authored: Fri Jul 1 11:10:54 2016 +0200 Committer: Maximilian Michels <[email protected]> Committed: Fri Jul 1 15:22:31 2016 +0200 ---------------------------------------------------------------------- .../main/java/org/apache/flink/client/program/ClusterClient.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/a3aea279/flink-clients/src/main/java/org/apache/flink/client/program/ClusterClient.java ---------------------------------------------------------------------- diff --git a/flink-clients/src/main/java/org/apache/flink/client/program/ClusterClient.java b/flink-clients/src/main/java/org/apache/flink/client/program/ClusterClient.java index 12a7a39..d5057b8 100644 --- a/flink-clients/src/main/java/org/apache/flink/client/program/ClusterClient.java +++ b/flink-clients/src/main/java/org/apache/flink/client/program/ClusterClient.java @@ -373,6 +373,7 @@ public abstract class ClusterClient { } try { + logAndSysout("Submitting job with JobID: " + jobGraph.getJobID() + ". Waiting for job completion."); this.lastJobID = jobGraph.getJobID(); return JobClient.submitJobAndWait(actorSystem, leaderRetrievalService, jobGraph, timeout, printStatusDuringExecution, classLoader); @@ -398,6 +399,7 @@ public abstract class ClusterClient { } try { + logAndSysout("Submitting Job with JobID: " + jobGraph.getJobID() + ". Returning after job submission."); JobClient.submitJobDetached(jobManagerGateway, jobGraph, timeout, classLoader); return new JobSubmissionResult(jobGraph.getJobID()); } catch (JobExecutionException e) {
