You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by mx...@apache.org on 2016/07/01 13:22:10 UTC
[3/7] flink git commit: [FLINK-3667] print JobID on submission
[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 <mx...@apache.org>
Authored: Fri Jul 1 11:10:54 2016 +0200
Committer: Maximilian Michels <mx...@apache.org>
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) {