Github user GJL commented on a diff in the pull request:

    https://github.com/apache/flink/pull/5648#discussion_r172837682
  
    --- Diff: 
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java 
---
    @@ -404,16 +404,25 @@ public void start() throws Exception {
                final JobManagerRunner jobManagerRunner = 
jobManagerRunners.get(jobId);
     
                if (jobManagerRunner != null) {
    -                   return 
jobManagerRunner.getJobManagerGateway().requestJobStatus(timeout);
    -           } else {
    -                   final JobDetails jobDetails = 
archivedExecutionGraphStore.getAvailableJobDetails(jobId);
    -
    -                   if (jobDetails != null) {
    -                           return 
CompletableFuture.completedFuture(jobDetails.getStatus());
    -                   } else {
    -                           return FutureUtils.completedExceptionally(new 
FlinkJobNotFoundException(jobId));
    +                   try {
    +                           return 
jobManagerRunner.getJobManagerGateway().requestJobStatus(timeout);
    --- End diff --
    
    I think methods such as `requestJob` and `requestOperatorBackPressureStats` 
are equally affected by this bug. I would also like to hear @tillrohrmann's 
opinion first before proceeding.


---

Reply via email to