Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5107#discussion_r154747386 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java --- @@ -534,6 +536,40 @@ public void handleError(final Exception exception) { onFatalError(new DispatcherException("Received an error from the LeaderElectionService.", exception)); } + //------------------------------------------------------ + // SubmittedJobGraphListener + //------------------------------------------------------ + + @Override + public void onAddedJobGraph(final JobID jobId) { + runAsync(() -> { + final SubmittedJobGraph submittedJobGraph; + try { + submittedJobGraph = submittedJobGraphStore.recoverJobGraph(jobId); + } catch (final Exception e) { + log.error("Could not submit job {}.", jobId, e); --- End diff -- Changed it.
---