[ https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
zhijiang closed FLINK-4364. --------------------------- > Implement heartbeat logic between TaskManager and JobManager > ------------------------------------------------------------ > > Key: FLINK-4364 > URL: https://issues.apache.org/jira/browse/FLINK-4364 > Project: Flink > Issue Type: Sub-task > Components: Cluster Management > Reporter: zhijiang > Assignee: zhijiang > > It is part of work for FLIP-6. > The {{HeartbeatManager}} is mainly used for monitoring heartbeat target and > reporting payloads. > For {{JobManager}} side, it would trigger monitoring the {{HeartbeatTarget}} > when receive registration from {{TaskManager}}, and schedule a task to > {{requestHeartbeat}} at interval time. If not receive heartbeat response > within duration time, the {{HeartbeatListener}} will notify heartbeat > timeout, then the {{JobManager}} should remove the internal registered > {{TaskManager}}. > For {{TaskManger}} side, it would trigger monitoring the {{HeartbeatTarget}} > when receive registration acknowledgement from {{JobManager}}. An it will > also be notified heartbeat timeout if not receive heartbeat request from > {{JobManager}} within duration time. > The current implementation will not interact payloads via heartbeat, and it > can be added if needed future. -- This message was sent by Atlassian JIRA (v6.3.15#6346)