[GitHub] flink pull request #5944: [FLINK-8900] [yarn] Set correct application status...

[StephanEwen]

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

    https://github.com/apache/flink/pull/5944#discussion_r185732563
  
    --- Diff: 
flink-yarn/src/main/java/org/apache/flink/yarn/entrypoint/YarnJobClusterEntrypoint.java
 ---
    @@ -131,6 +133,17 @@ protected JobGraph retrieveJobGraph(Configuration 
configuration) throws FlinkExc
                }
        }
     
    +   @Override
    +   protected void 
registerShutdownActions(CompletableFuture<ApplicationStatus> terminationFuture) 
{
    +           terminationFuture.whenComplete((status, throwable) ->
    --- End diff --
    
    Will update


---