Hi Robert,
unfortunately there are no signs of what is going wrong in the logs. The
last log messages are about succesful registration of the TaskManagers.
I'm also fairly sure it must be something in my VM that is causing this,
because when I start the yarn-session from a login node that is on the same
network as the hadoop cluster there are no problems registering with the
JobManager. I did also notice the following message in the local console:
12:30:27,173 WARN Remoting
- Tried to associate with unreachable remote address [akka.tcp://
flink@145.100.41.13:41539]. Address is now gated for 5000 ms, all messages
to this address will be delivered to dead letters. Reason: connection timed
out: /145.100.41.13:41539
I can ping the JobManager fine from with VM. Could there be some invalid or
missing configuration on my side?
Cheers,
Pieter
2016-02-06 12:54 GMT+01:00 Robert Metzger <rmetz...@apache.org>:
> Hi,
>
> did you check the logs of the JobManager itself? Maybe it'll tell us
> already whats going on.
>
> On Sat, Feb 6, 2016 at 12:14 PM, Pieter Hameete <phame...@gmail.com>
> wrote:
>
>> 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
>>
>>
>>
>
