flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From m..@apache.org
Subject [3/7] flink git commit: [FLINK-3667] print JobID on submission
Date Fri, 01 Jul 2016 13:22:10 GMT
[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 <mxm@apache.org>
Authored: Fri Jul 1 11:10:54 2016 +0200
Committer: Maximilian Michels <mxm@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) {


Mime
View raw message