zhangjing created FLINK-4449: -------------------------------- Summary: Heartbeat Manager between ResourceManager and TaskExecutor Key: FLINK-4449 URL: https://issues.apache.org/jira/browse/FLINK-4449 Project: Flink Issue Type: Sub-task Components: Cluster Management Reporter: zhangjing Assignee: zhangjing
HeartbeatManager is responsible for heartbeat between resourceManager to TaskExecutor 1. Register taskExecutors register heartbeat targets. If the heartbeat response for these targets is not reported in time, mark target failed and notify resourceManager 2. trigger heartbeat trigger heartbeat from resourceManager to TaskExecutor periodically taskExecutor report slot allocation in the heartbeat response ResourceManager sync self slot allocation with the heartbeat response -- This message was sent by Atlassian JIRA (v6.3.4#6332)