flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Deepak Jha <dkjhan...@gmail.com>
Subject Remote TaskManager Connection Problem
Date Fri, 04 Mar 2016 01:48:31 GMT
Hi All,
I've created 2 docker containers on my local machine, one running
JM(192.168.99.104) and other running TM. I was expecting to see TM in the
JM UI but it did not happen. On looking into the TM logs I see following
lines


01:29:50,862 DEBUG org.apache.flink.runtime.taskmanager.TaskManager
     - Starting TaskManager process reaper
01:29:50,868 INFO  org.apache.flink.runtime.filecache.FileCache
     - User file cache uses directory
/tmp/flink-dist-cache-be63f351-2bce-48ef-bbc4-fb0f40fecd49
01:29:51,093 INFO  org.apache.flink.runtime.taskmanager.TaskManager
     - Starting TaskManager actor at
akka://flink/user/taskmanager#1222392284.
01:29:51,095 INFO  org.apache.flink.runtime.taskmanager.TaskManager
     - TaskManager data connection information: 140efeb188cc (dataPort=6122)
01:29:51,096 INFO  org.apache.flink.runtime.taskmanager.TaskManager
     - TaskManager has 1 task slot(s).
01:29:51,097 INFO  org.apache.flink.runtime.taskmanager.TaskManager
     - Memory usage stats: [HEAP: 386/494/494 MB, NON HEAP: 30/31/-1 MB
(used/committed/max)]
01:29:51,104 INFO  org.apache.flink.runtime.taskmanager.TaskManager
     - Trying to register at JobManager akka.tcp://
flink@192.168.99.104:6123/user/jobmanager (attempt 1, timeout: 500
milliseconds)
01:29:51,633 INFO  org.apache.flink.runtime.taskmanager.TaskManager
     - Trying to register at JobManager akka.tcp://
flink@192.168.99.104:6123/user/jobmanager (attempt 2, timeout: 1000
milliseconds)
01:29:52,652 INFO  org.apache.flink.runtime.taskmanager.TaskManager
     - Trying to register at JobManager akka.tcp://
flink@192.168.99.104:6123/user/jobmanager (attempt 3, timeout: 2000
milliseconds)
01:29:54,672 INFO  org.apache.flink.runtime.taskmanager.TaskManager
     - Trying to register at JobManager akka.tcp://
flink@192.168.99.104:6123/user/jobmanager (attempt 4, timeout: 4000
milliseconds)
01:29:58,693 INFO  org.apache.flink.runtime.taskmanager.TaskManager
     - Trying to register at JobManager akka.tcp://
flink@192.168.99.104:6123/user/jobmanager (attempt 5, timeout: 8000
milliseconds)
01:30:06,702 INFO  org.apache.flink.runtime.taskmanager.TaskManager
     - Trying to register at JobManager akka.tcp://
flink@192.168.99.104:6123/user/jobmanager (attempt 6, timeout: 16000
milliseconds)


However, from TM i am able to reach JM on port 6123
root@140efeb188cc:/# nc -v 192.168.99.104 6123
Connection to 192.168.99.104 6123 port [tcp/*] succeeded!


masters file on TM contains
192.168.99.104:8080

Did anyone face this issue with remote JM/TM combination ?

-- 
Thanks,
Deepak Jha

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message