[ https://issues.apache.org/jira/browse/FLINK-4354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15854030#comment-15854030 ]
ASF GitHub Bot commented on FLINK-4354: --------------------------------------- Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/2770#discussion_r99588554 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java --- @@ -1099,4 +1121,23 @@ public void run() { }); } } + + private final class ResourceManagerHeartbeatListener implements HeartbeatListener { + + ResourceManagerHeartbeatListener() { + } + + @Override + public void notifyHeartbeatTimeout(ResourceID resourceID) { + } --- End diff -- What happens in case of a timeout? > Implement TaskManager side of heartbeat from ResourceManager > ------------------------------------------------------------- > > Key: FLINK-4354 > URL: https://issues.apache.org/jira/browse/FLINK-4354 > Project: Flink > Issue Type: Sub-task > Components: Cluster Management > Reporter: Zhijiang Wang > Assignee: Zhijiang Wang > > The {{ResourceManager}} initiates heartbeat messages via the {{RmLeaderID}}. > The {{TaskManager}} transmits its slot availability with each heartbeat. That > way, the RM will always know about available slots. -- This message was sent by Atlassian JIRA (v6.3.15#6346)