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.
---