Hi Tison,
These can be still be set but judging from the documentation [1], they have
never been very relevant in Flink:
Heartbeat interval for Akka's transport failure detector. Since Flink
uses
TCP, the detector is not necessary. Therefore, the detector is disabled
by
setting the in
Hi Gray,
Thanks for your useful information! Here I wonder if the following configs
still valid on FLIP-6 mode.
1. akka.transport.heartbeat.interval
2. akka.transport.heartbeat.pause
It seems they are different from HeartbeatServices and possibly still valid.
Best,
tison.
Gary Yao 于2018年9月10
I should add that in FLIP-6 mode we are not relying on Akka's DeathWatch but
because Flink's RPC framework uses Akka, you are still able to configure the
other Akka config options [1].
[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.5/ops/config.html#distributed-coordination-via-akka
Hi Tony,
You are right that with FLIP-6 Akka is abstracted away. If you want custom
heartbeat settings, you can configure the options below [1]:
heatbeat.interval
heartbeat.timeout
The config option taskmanager.exit-on-fatal-akka-error is also not relevant
anymore. I closest I can think
