Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5107#discussion_r154357254
--- 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 --
Maybe "could not recover job".
---
