flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Gary Yao <g...@data-artisans.com>
Subject Re: Question about akka configuration for FLIP-6
Date Mon, 10 Sep 2018 05:50:15 GMT
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

On Mon, Sep 10, 2018 at 7:38 AM, Gary Yao <gary@data-artisans.com> wrote:

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

Mime
View raw message