I'm running a flink-cluster (a mini one with just one node); but the
problem is that my TaskManager can't reach to my JobManager!
Here are logs from TaskManager
...
Trying to register at JobManager akka.tcp://flink@MY_PRIV_IP/user/jobmanager
(attempt 20, timeout: 30 seconds)
Trying to register at JobManager akka.tcp://flink@MY_PRIV_IP/user/jobmanager
(attempt 21, timeout: 30 seconds)
Trying to register at JobManager akka.tcp://flink@MY_PRIV_IP/user/jobmanager
(attempt 22, timeout: 30 seconds)
Trying to register at JobManager akka.tcp://flink@MY_PRIV_IP/user/jobmanager
(attempt 23, 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 in my JobManger stdout:
Resource Manager associating with leading JobManager
Actor[akka://flink/user/jobmanager#-275619168] - leader session null
TaskManager ResourceID{resourceId='1132cbdaf2d8204e5e42e321e8592754'} has
started.
Registered TaskManager at MY_PRIV_IP (akka://flink/deadLetters) as
7d9568445b4557a74d05a0771a08ad9c. Current number of registered hosts is 1.
Current number of alive task slots is 20.
What's the meaning of these lines? Where should I look for the solution?
--
رضا سامعی / http://samee.blog.ir
