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 of is taskmanager.registration.timeout [2].

Best,
Gary


[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.5/ops/config.html#heartbeat-manager
[2]
https://ci.apache.org/projects/flink/flink-docs-release-1.5/ops/config.html#taskmanager-registration-timeout

On Mon, Sep 10, 2018 at 4:24 AM, Tony Wei <tony19920...@gmail.com> wrote:

> Hi,
>
> I'm going to migrate my flink cluster from 1.4.0 to 1.5.3, and I have been
> trying to map config file
> to the latest version. I used to use these three configuration. Are they
> still needed in FLIP-6 mode?
> Moreover, is any akka config still needed in FLIP-6 mode? Since I had a
> impression that FLIP-6
> tried to get rid of akka and use its own rpc interface. Please correct me
> if I misunderstood. Thanks.
>
> akka.watch.heartbeat.interval
> akka.watch.heartbeat.pause
> taskmanager.exit-on-fatal-akka-error
>
> Best Regards,
> Tony Wei
>

Reply via email to