Github user suez1224 commented on a diff in the pull request: https://github.com/apache/flink/pull/4729#discussion_r141822004 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java --- @@ -228,7 +234,14 @@ public void startNewWorker(ResourceProfile resourceProfile) { @Override public void stopWorker(ResourceID resourceID) { --- End diff -- Do you mean something like MesosWorkerStore.Worker in MesosResourceManager, which has both the taskId (used as resourceID) and other context info for the Mesos worker?
---