[FLINK-4364] Implement heartbeat logic between TaskManager and JobManager

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Component/s: Runtime / Coordination
• Assignee: Zhijiang
• Reporter: Zhijiang
• Created: 10/Aug/16 10:53
• Updated: 28/Feb/19 14:13
• Resolved: 17/Mar/17 16:00

Description

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.

Issue Links

• is blocked by: FLINK-4478 Implement heartbeat logic
• is part of: FLINK-4478 Implement heartbeat logic
• links to: GitHub Pull Request #2798
• links to: GitHub Pull Request #3151