Re: Running Flink 1.0.0 on YARN

2016-03-11 Thread Robert Metzger
Hi, the first issue you are describing is expected. Flink is starting the web interface on the container running the JobManager, not on the resource manager. Also, the port is allocated dynamically, to avoid port collisions. So its not started on 8081. However, you can access the web interface fro

Running Flink 1.0.0 on YARN

2016-03-10 Thread Ashutosh Kumar
I have a yarn setup with 1 master and 2 slaves. When I run yarn session with bin/yarn-session.sh -n 2 -jm 1024 -tm 1024 and submit job with bin/flink run examples/batch/WordCount.jar , the job succeeds . It shows status on yarn UI http://x.x.x.x:8088/cluster . However it does not show anythin