Hi Saiph,

are you sure that the jobs are cancelled because the client disconnects?

For the different timeouts, check the configuration page:
https://ci.apache.org/projects/flink/flink-docs-release-0.10/setup/config.html
and search for "heartbeat".

On Fri, Feb 19, 2016 at 8:04 PM, Saiph Kappa <saiph.ka...@gmail.com> wrote:

> Hi,
>
> I have a Flink client application that launches jobs to remote clusters.
> However I'm getting my jobs cancelled:
> "18:25:29,650 WARN
> akka.remote.ReliableDeliverySupervisor                        - Association
> with remote system [akka.tcp://flink@127.0.0.1:52929] has failed, address
> is now gated for [5000] ms. Reason is: [Disassociated]."
>
> How can I increase the akka heartbeat interval? Where should I set that
> configuration parameter, in the client or in the Flink clusters, and in
> which file.
>
> Thanks.
>
>

Reply via email to