GitHub user wangzhijiang999 opened a pull request:
https://github.com/apache/flink/pull/3151
[FLINK-4364][runtime]mplement TaskManager side of heartbeat from JobMâ¦
1. **TaskManagerRunner** creates **HeartbeatManagerImpl** components when
constructs the **TaskManager**.
2. **TaskManager** begins to monitor the JobManager when registration at
new job leader successful.
3. Currently the payload will be null for interaction between
**TaskManager** and **JobManager**, it can be expanded if needed later. Also
the logic of heartbeat timeout is not implemented yet, and maybe realized in
failover detection issue.
4. The **JobManager** side implementation will be realized in another jira.
@tillrohrmann for review please!
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/wangzhijiang999/flink FLINK-4364
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/3151.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #3151
----
commit 362f717b0ec50d8cc864d2f2efd432a5efbfd24a
Author: æ·æ± <[email protected]>
Date: 2017-01-18T11:08:19Z
[FLINK-4364][runtime]mplement TaskManager side of heartbeat from JobManager
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
