Hi, can you maybe (if you want also private) send me the full logs of the jobmanager? The messages you've posted here are logged at DEBUG level. They don't indicate an erroneous behavior of the system.
On Fri, Feb 19, 2016 at 8:44 PM, Saiph Kappa <saiph.ka...@gmail.com> wrote: > These were the parameters that I set btw: > > akka.watch.heartbeat.interval: 100 > akka.transport.heartbeat.interval: 1000 > > On Fri, Feb 19, 2016 at 7:43 PM, Saiph Kappa <saiph.ka...@gmail.com> > wrote: > >> 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. >>>> >>>> >>> >> >
