Kurt Young created FLINK-4348:
---------------------------------
Summary: implement communication from ResourceManager to
TaskManager
Key: FLINK-4348
URL: https://issues.apache.org/jira/browse/FLINK-4348
Project: Flink
Issue Type: Sub-task
Components: Cluster Management
Reporter: Kurt Young
There are mainly 3 logics initiated from RM to TM:
* Heartbeat, RM use heartbeat to sync with TM's slot status
* SlotRequest, when RM decides to assign slot to JM, should first try to send
request to TM for slot. TM can either accept or reject this request.
* FailureNotify, in some corner cases, TM will be marked as invalid by cluster
manager master(e.g. yarn master), but TM itself does not realize. RM should
send failure notify to TM and TM can terminate itself
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)