I am not sure. For that particular machine I get messages like these: « myip:6123/user/jobmanager#291801197])) at akka://flink/user/$a from Actor[akka://flink/deadLetters]. ^[[34m[INFO]^[[0;39m o.a.f.r.c.JobClientActor - Connected to new JobManager akka.tcp://flink@myip:6123/user/jobmanager.
^[[34m[INFO]^[[0;39m o.a.f.r.c.JobClientActor - Sending message to JobManager akka.tcp://flink@myip:6123/user/jobmanager to submit job JOB1 (5f9cef0c2e4b69530bf1e2485e94d326) and wait for progress ^[[39m[DEBUG]^[[0;39m o.a.f.r.c.JobClientActor - Handled message LeaderSessionMessage(null,JobManagerActorRef(Actor[akka.tcp://flink@myip:6123/user/jobmanager#291801197])) in 48 ms from Actor[akka://flink/deadLetters]. ^[[39m[DEBUG]^[[0;39m o.a.f.r.c.JobClientActor - Handled message LeaderSessionMessage(null,JobManagerActorRef(Actor[akka.tcp://flink@myip:6123/user/jobmanager#291801197])) in 48 ms from Actor[akka://flink/deadLetters]. ^[[39m[DEBUG]^[[0;39m o.a.f.r.c.JobClientActor - Received message JobSubmitSuccess(2575d5ff5c10336beb7820a052a63623) at akka://flink/user/$a from Actor[akka.tcp://flink@myip:6123/user/jobmanager#1144818256]. » I tried to set the heartbeat interval in the cluster but it didn't solve the problem, should I try to set it in the client (how can I do it)? I see no other errors or exceptions on the log files. On Fri, Feb 19, 2016 at 7:07 PM, Robert Metzger <rmetz...@apache.org> wrote: > 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. >> >> >
