flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From zhijiangW <...@git.apache.org>
Subject [GitHub] flink pull request #3645: [FLINK-6120][Distributed Coordinator]Implement hea...
Date Wed, 29 Mar 2017 16:39:16 GMT
GitHub user zhijiangW opened a pull request:

    https://github.com/apache/flink/pull/3645

    [FLINK-6120][Distributed Coordinator]Implement heartbeat logic between JobManager and
ResourceManager

    It is part of work for Flip-6.
    
    The `HeartbeatManager` is mainly used for monitoring heartbeat target and reporting payloads.
    
    For `ResourceManager` side, it would trigger monitor the `HeartbeatTarget` when receive
registration from `JobManager`, 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 `ResourceManager` will remove the internal connection with `JobManager`
and also notify the `JobManager` to close the corresponding connection via RPC.
    
    For `JobManger` side, it would trigger monitor the `HeartbeatTarget` when receive registration
success from `ResourceManager`. It will also be notified heartbeat timeout if not receive
heartbeat request from `ResourceManager` within duration time and close connection as a result.
    
    The current implementation will not interact payloads via heartbeat, and it can be added
if needed future.


You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/zhijiangW/flink heartbeatJMRM

Alternatively you can review and apply these changes as the patch at:

    https://github.com/apache/flink/pull/3645.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 #3645
    
----
commit a8034dad005600f396b8ea8cd8c7101b51734da2
Author: Zhijiang <wangzhijiang999@aliyun.com>
Date:   2017-03-29T16:30:29Z

    [FLINK-6120][Distributed Coordinator]Implement heartbeat logic between JobManager and
ResourceManager

----


---
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 infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

Mime
View raw message