Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5309#discussion_r163899592 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java --- @@ -331,13 +331,13 @@ public void start() throws Exception { } @Override - public CompletableFuture<AccessExecutionGraph> requestJob(JobID jobId, Time timeout) { + public CompletableFuture<ArchivedExecutionGraph> requestJob(JobID jobId, Time timeout) { --- End diff -- True will change it.
---