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 <[email protected]>
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 [email protected] or file a JIRA ticket
with INFRA.
---
