Skip to content

Commit

Permalink
[FLINK-26032][client] add log info for the status of job submission a…
Browse files Browse the repository at this point in the history
…nd execution result.

This closes apache#18677.
  • Loading branch information
JingGe authored and tillrohrmann committed Feb 9, 2022
1 parent 890b83c commit 8ce9632
Showing 1 changed file with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -118,6 +118,7 @@ private JobExecutionResult getJobExecutionResult(final JobClient jobClient) thro
if (!suppressSysout) {
System.out.println(jobExecutionResult);
}
LOG.info(String.valueOf(jobExecutionResult));
} else {
jobExecutionResult = new DetachedJobExecutionResult(jobClient.getJobID());
}
Expand All @@ -133,7 +134,7 @@ public JobClient executeAsync(String jobName) throws Exception {
if (!suppressSysout) {
System.out.println("Job has been submitted with JobID " + jobClient.getJobID());
}

LOG.info("Job has been submitted with JobID {}", jobClient.getJobID());
return jobClient;
}

Expand Down

0 comments on commit 8ce9632

Please sign in to comment.