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

    https://github.com/apache/flink/pull/6132#discussion_r198489897
  
    --- Diff: 
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManager.java
 ---
    @@ -619,7 +619,11 @@ public void taskTerminated(TaskMonitor.TaskTerminated 
message) {
                        startNewWorker(launched.profile());
                }
     
    -           closeTaskManagerConnection(id, new 
Exception(status.getMessage()));
    +           final Exception terminatedCause = new 
Exception(status.getMessage());
    --- End diff --
    
    let's call it `terminationCause`


---

Reply via email to