[GitHub] flink pull request #5648: [FLINK-8887][flip-6] ClusterClient.getJobStatus ca...

[yanghua]

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

    https://github.com/apache/flink/pull/5648#discussion_r172782747
  
    --- 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 --
    
    OK, I will try this way, thanks!


---