flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tillrohrmann <...@git.apache.org>
Subject [GitHub] flink pull request #2742: [FLINK-4944] Replace Akka's death watch with own h...
Date Wed, 02 Nov 2016 15:59:34 GMT
GitHub user tillrohrmann opened a pull request:

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

    [FLINK-4944] Replace Akka's death watch with own heartbeat on the TM side

    This PR introduces the HeartbeatActor which is used by the TaskManager to monitor the
    JobManager. The HeartbeatActor constantly sends Heartbeat messages to the JobManager
    which responds with a HeartbeatResponse. If the HeartbeatResponse fails to be received
    for an acceptable heartbeat pause, then the HeartbeatActor sends a HeartbeatTimeout
    message to the owner of the HeartbeatActor.
    
    The acceptable heartbeat pause can be extended by the HeartbeatActor if it detects that
    it has been stalled by garbage collection, for example.
    
    The HeartbeatActor is started as a child actor of the TaskManager.
    
    Add ClusterOptions
    
    Add comments

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

    $ git pull https://github.com/tillrohrmann/flink removeDeathWatch

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

    https://github.com/apache/flink/pull/2742.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 #2742
    
----
commit 4437ef25a3f7a084b3f1a577411a7863410bfde3
Author: Till Rohrmann <trohrmann@apache.org>
Date:   2016-11-01T20:14:40Z

    [FLINK-4944] Replace Akka's death watch with own heartbeat on the TM side
    
    This PR introduces the HeartbeatActor which is used by the TaskManager to monitor the
    JobManager. The HeartbeatActor constantly sends Heartbeat messages to the JobManager
    which responds with a HeartbeatResponse. If the HeartbeatResponse fails to be received
    for an acceptable heartbeat pause, then the HeartbeatActor sends a HeartbeatTimeout
    message to the owner of the HeartbeatActor.
    
    The acceptable heartbeat pause can be extended by the HeartbeatActor if it detects that
    it has been stalled by garbage collection, for example.
    
    The HeartbeatActor is started as a child actor of the TaskManager.
    
    Add ClusterOptions
    
    Add comments

----


---
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