This is an automated email from the ASF dual-hosted git repository. mapohl pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit c5248b62abf55970aca8780fd816310f90f7cbd8 Author: snuyanzin <[email protected]> AuthorDate: Thu Sep 8 09:24:39 2022 +0200 [FLINK-29223][coordination] Add missing output info for jobs already reached terminal state --- .../runtime/dispatcher/runner/SessionDispatcherLeaderProcess.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/runner/SessionDispatcherLeaderProcess.java b/flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/runner/SessionDispatcherLeaderProcess.java index 63187002acc..5b74536781d 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/runner/SessionDispatcherLeaderProcess.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/runner/SessionDispatcherLeaderProcess.java @@ -148,6 +148,10 @@ public class SessionDispatcherLeaderProcess extends AbstractDispatcherLeaderProc for (JobID jobId : jobIds) { if (!recoveredDirtyJobResults.contains(jobId)) { tryRecoverJob(jobId).ifPresent(recoveredJobGraphs::add); + } else { + log.info( + "Skipping recovery of a job with job id {}, because it already reached a globally terminal state", + jobId); } }
