提交 a3aea279 编写于 作者: M Maximilian Michels

[FLINK-3667] print JobID on submission

上级 44b3bc45
......@@ -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) {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册