flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Kurt Young (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-4348) implement communication from ResourceManager to TaskManager
Date Wed, 10 Aug 2016 08:31:20 GMT
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

View raw message