Re: What's the meaning of "Registered `TaskManager` at akka://flink/deadLetters " ?

2018-01-19 Thread Piotr Nowojski
;> [5000] ms. Reason: [Disassociated] >> >> But it will not decrement the number of available task-managers! >> and when I start my signle task-manager again, it logs: >> >> 2018-01-15 13:32:52,753 INFO >> org.apache.flink.runtime.instance.InstanceManager

Re: What's the meaning of "Registered `TaskManager` at akka://flink/deadLetters " ?

2018-01-17 Thread Reza Samee
now gated for [5000] ms. Reason: [Disassociated] > > But it will not decrement the number of available task-managers! > and when I start my signle task-manager again, it logs: > > 2018-01-15 13:32:52,753 INFO org.apache.flink.runtime. > instance.InstanceManager - Regi

Re: What's the meaning of "Registered `TaskManager` at akka://flink/deadLetters " ?

2018-01-15 Thread Piotr Nowojski
ason: [Disassociated] > > But it will not decrement the number of available task-managers! > and when I start my signle task-manager again, it logs: > > 2018-01-15 13:32:52,753 INFO > org.apache.flink.runtime.instance.InstanceManager - Registered > TaskManager

Re: What's the meaning of "Registered `TaskManager` at akka://flink/deadLetters " ?

2018-01-15 Thread Reza Samee
not decrement the number of available task-managers! and when I start my signle task-manager again, it logs: 2018-01-15 13:32:52,753 INFO org.apache.flink.runtime.instance.InstanceManager - Registered TaskManager at ??? (akka://flink/deadLetters) as 626846ae27a833cb094eeeb047a6a72c. Cur

Re: What's the meaning of "Registered `TaskManager` at akka://flink/deadLetters " ?

2018-01-10 Thread Piotr Nowojski
gt; > My "JobManager UI" shows my TaskManager with this Path & ID: > "akka://flink/deadLetters" ( in TaskManagers tab) > And I found these lines in my JobManger stdout: > > Resource Manager associating with leading JobManager > Actor[akka://flink/user/jo

What's the meaning of "Registered `TaskManager` at akka://flink/deadLetters " ?

2018-01-09 Thread Reza Samee
3, timeout: 30 seconds) Trying to register at JobManager akka.tcp://flink@MY_PRIV_IP/user/jobmanager (attempt 24, timeout: 30 seconds) ... My "JobManager UI" shows my TaskManager with this Path & ID: "akka://flink/deadLetters" ( in TaskManagers tab) And I found these lines

Re: Flink deadLetters

2015-07-21 Thread Ufuk Celebi
OK, but I need to get back to you soon to test the fix as well. :D I hope that's OK. ;) On 21 Jul 2015, at 17:45, Flavio Pompermaier wrote: > Setting env.getconfig().setExecutionMode(ExecutionMode.PIPELINED_FORCED) make > it work :)

Re: Flink deadLetters

2015-07-21 Thread Flavio Pompermaier
; > Cheers, > > Till > > > > On Fri, Jul 17, 2015 at 6:30 PM, Flavio Pompermaier < > pomperma...@okkam.it> wrote: > > Hi to all, > > > > > > > > > > my job seems to be stucked and there's nothing logged also in debug mode. > > The only strange thing is a > > > > Received message SendHeartbeat at akka://flink/user/taskmanager_1 from > Actor[akka://flink/deadLetters]. > > > > Could it be a symptom of a problem? > > > > Best, > > Flavio > > > > > > > >

Re: Flink deadLetters

2015-07-21 Thread Ufuk Celebi
> > On Fri, Jul 17, 2015 at 6:30 PM, Flavio Pompermaier > wrote: > Hi to all, > > > > > my job seems to be stucked and there's nothing logged also in debug mode. > The only strange thing is a > > Received message SendHeartbeat at akka://flink/user/taskmanager_1 from > Actor[akka://flink/deadLetters]. > > Could it be a symptom of a problem? > > Best, > Flavio > > >

Re: Flink deadLetters

2015-07-21 Thread Stephan Ewen
rs, >>> Till >>> >>> On Fri, Jul 17, 2015 at 6:30 PM, Flavio Pompermaier < >>> pomperma...@okkam.it> wrote: >>> >>>> Hi to all, >>>> >>>> my job seems to be stucked and there's nothing logged also in debug >>>> mode. >>>> The only strange thing is a >>>> >>>> Received message SendHeartbeat at akka://flink/user/taskmanager_1 from >>>> Actor[akka://flink/deadLetters]. >>>> >>>> Could it be a symptom of a problem? >>>> >>>> Best, >>>> Flavio >>>> >>> >>> >

Re: Flink deadLetters

2015-07-20 Thread Till Rohrmann
gt;> What kind of job is it? >> >> Cheers, >> Till >> >> On Fri, Jul 17, 2015 at 6:30 PM, Flavio Pompermaier > > wrote: >> >>> Hi to all, >>> >>> my job seems to be stucked and there's nothing logged also in debug mode. >&

Re: Flink deadLetters

2015-07-18 Thread Flavio Pompermaier
ucked and there's nothing logged also in debug mode. >> The only strange thing is a >> >> Received message SendHeartbeat at akka://flink/user/taskmanager_1 from >> Actor[akka://flink/deadLetters]. >> >> Could it be a symptom of a problem? >> >> Best, >> Flavio >> > >

Re: Flink deadLetters

2015-07-17 Thread Till Rohrmann
all, > > my job seems to be stucked and there's nothing logged also in debug mode. > The only strange thing is a > > Received message SendHeartbeat at akka://flink/user/taskmanager_1 from > Actor[akka://flink/deadLetters]. > > Could it be a symptom of a problem? > > Best, > Flavio >

Flink deadLetters

2015-07-17 Thread Flavio Pompermaier
Hi to all, my job seems to be stucked and there's nothing logged also in debug mode. The only strange thing is a Received message SendHeartbeat at akka://flink/user/taskmanager_1 from Actor[akka://flink/deadLetters]. Could it be a symptom of a problem? Best, Flavio