Re: Flink on YARN: Stuck on "Trying to register at JobManager"

2016-02-08 Thread Pieter Hameete
Solved: indeed it needed to be built for YARN 2.7.1 specifically. Cheers! 2016-02-08 19:13 GMT+01:00 Robert Metzger : > Mh, that's weird. Maybe both resource managers are marked as "standby"? > Not sure what can cause this issue. > > Which YARN version are you using? Maybe you need to build Flink

Re: Flink on YARN: Stuck on "Trying to register at JobManager"

2016-02-08 Thread Robert Metzger
Mh, that's weird. Maybe both resource managers are marked as "standby"? Not sure what can cause this issue. Which YARN version are you using? Maybe you need to build Flink against that specific hadoop version yourself. On Mon, Feb 8, 2016 at 5:50 PM, Pieter Hameete wrote: > After downloading an

Re: Flink on YARN: Stuck on "Trying to register at JobManager"

2016-02-08 Thread Pieter Hameete
After downloading and building the 1.0-SNAPSHOT from the master branch I do run into another problem when starting a YARN cluster. The startup now infinitely loops at the following step: 17:39:12,369 INFO org.apache.hadoop.yarn.client.ConfiguredRMFailoverProxyProvider - Failing over to rm2 17:39:

Re: Flink on YARN: Stuck on "Trying to register at JobManager"

2016-02-08 Thread Pieter Hameete
Ive tried setting the yarn.application-master.port property in flink-conf.yaml to a range suggested in https://ci.apache.org/projects/flink/flink-docs-master/setup/yarn_setup.html#running-flink-on-yarn-behind-fi rewalls The JobManager does not seem to be picking the property up. Am I setting this

Re: Flink on YARN: Stuck on "Trying to register at JobManager"

2016-02-08 Thread Pieter Hameete
Matter of RTFM eh ;-) thx and sorry for the bother. 2016-02-08 17:06 GMT+01:00 Robert Metzger : > You said earlier that you are using Flink 0.10. The feature is only > available in 1.0-SNAPSHOT. > > On Mon, Feb 8, 2016 at 4:53 PM, Pieter Hameete wrote: > >> Ive tried setting the yarn.application

Re: Flink on YARN: Stuck on "Trying to register at JobManager"

2016-02-08 Thread Robert Metzger
You said earlier that you are using Flink 0.10. The feature is only available in 1.0-SNAPSHOT. On Mon, Feb 8, 2016 at 4:53 PM, Pieter Hameete wrote: > Ive tried setting the yarn.application-master.port property in > flink-conf.yaml to a range suggested in > https://ci.apache.org/projects/flink/f

Re: Flink on YARN: Stuck on "Trying to register at JobManager"

2016-02-07 Thread Pieter Hameete
I found the relevant information on the website. Ill consult with the cluster admin tomorrow, thanks for the help :-) - Pieter 2016-02-07 19:31 GMT+01:00 Robert Metzger : > Hi, > > we had other users with a similar issue as well. There is a configuration > value which allows you to specify a sin

Re: Flink on YARN: Stuck on "Trying to register at JobManager"

2016-02-07 Thread Robert Metzger
Hi, we had other users with a similar issue as well. There is a configuration value which allows you to specify a single port or a range of ports for the JobManager to allocate when running on YARN. Note that when using this with a single port, the JMs may collide. On Sun, Feb 7, 2016 at 7:25 P

Re: Flink on YARN: Stuck on "Trying to register at JobManager"

2016-02-07 Thread Pieter Hameete
Hi Stephan, surely it seems this way! I must not be the first with this issue though? I'll have to contact the cluster admins to find a solution together. What would be a way of make the JobManagers accessible from outside the network, because the IP and port number changes every time. Alternativ

Re: Flink on YARN: Stuck on "Trying to register at JobManager"

2016-02-06 Thread Stephan Ewen
Yeah, sounds a lot like the client cannot connect to the JobManager port. The ports to communicate with HDFS and the YARN resource manager may be whitelisted r forwarded, so you can submit the YARN session, but then not connect to the JobManager afterwards. On Sat, Feb 6, 2016 at 2:11 PM, Piete

Re: Flink on YARN: Stuck on "Trying to register at JobManager"

2016-02-06 Thread Pieter Hameete
Hi Max! I'm using Flink 0.10.1 and indeed the cluster seems to be created fine, all in the JobManager Web UI looks good. It seems like the JobManager initiates the connection with my VM and cannot reach it. It could be that this is similar to the problem here: http://apache-spark-user-list.10015

Re: Flink on YARN: Stuck on "Trying to register at JobManager"

2016-02-06 Thread Maximilian Michels
Hi Pieter, Which version of Flink are you using? It appears you've created a Flink YARN cluster but you can't reach the JobManager afterwards. Cheers, Max On Sat, Feb 6, 2016 at 1:42 PM, Pieter Hameete wrote: > Hi Robert, > > unfortunately there are no signs of what is going wrong in the logs.

Re: Flink on YARN: Stuck on "Trying to register at JobManager"

2016-02-06 Thread Pieter Hameete
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 t

Re: Flink on YARN: Stuck on "Trying to register at JobManager"

2016-02-06 Thread Robert Metzger
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 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 g

Flink on YARN: Stuck on "Trying to register at JobManager"

2016-02-06 Thread Pieter Hameete
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