Hi Guys! Im attempting to run Flink on YARN, but I run into an issue. Im starting the Flink YARN session from an Ubuntu 14.04 VM. All goes well until after the JobManager web UI is started:
JobManager web interface address http://head05.hathi.surfsara.nl:8088/proxy/application_1452780322684_10532/ Waiting until all TaskManagers have connected 11:09:51,557 INFO org.apache.flink.yarn.ApplicationClient - Notification about new leader address akka.tcp:// flink@145.100.41.148:35666/user/jobmanager with session ID null. No status updates from the YARN cluster received so far. Waiting ... 11:09:51,578 INFO org.apache.flink.yarn.ApplicationClient - Received address of new leader akka.tcp:// flink@145.100.41.148:35666/user/jobmanager with session ID null. 11:09:51,583 INFO org.apache.flink.yarn.ApplicationClient - Disconnect from JobManager null. 11:09:51,595 INFO org.apache.flink.yarn.ApplicationClient - Trying to register at JobManager akka.tcp:// flink@145.100.41.148:35666/user/jobmanager. No status updates from the YARN cluster received so far. Waiting ... No status updates from the YARN cluster received so far. Waiting ... It then hangs on these last steps (trying to register, no status updates..) Im sure there must be a problem on my side that is causing me not to be able to register at the JobManager. What could cause such connection problems? Any tips are very welcome :-) Cheers and have a good weekend! - Pieter
