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