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

2018-01-19 Thread Piotr Nowojski
Hi, It seems like you have not opened some of the ports. As I pointed out in the first mail, please go through all of the config options regarding hostnames/ports (not only those that appear in the log files, maybe something is not being logged)

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

2018-01-15 Thread Piotr Nowojski
Hi, Could you post full job manager and task manager logs from startup until the first signs of the problem? Thanks, Piotrek > On 15 Jan 2018, at 11:21, Reza Samee wrote: > > Thanks for response; > And sorry the passed time. > > The JobManager & TaskManager logged

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

2018-01-15 Thread Reza Samee
Thanks for response; And sorry the passed time. The JobManager & TaskManager logged ports are open! Is this log OK? 2018-01-15 13:40:03,455 INFO org.apache.flink.runtime.webmonitor.JobManagerRetriever - New leader reachable under akka.tcp://flink@172.16.20.18:6123/user/jobmanager:null.

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

2018-01-09 Thread Reza Samee
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