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