[
https://issues.apache.org/jira/browse/FLINK-4364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-4364:
----------------------------
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 {{JobManager}} target
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.
was:
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 {{JobManager}} target
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.
> 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 {{JobManager}}
> target 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)
