Re: How to start a TaskManager and the Flink Query Interface from, Scala IDE (local run configuration)

2015-03-09 Thread Mihail Vieru
Yep, it works with the newest build. Was just a glitch in the matrix :) Thanks again! Mihail On 09.03.2015 21:14, Robert Metzger wrote: Mh. Thats weird. It looks like your JobManager is being started in the cluster mode. Can you pull the latest changes from master? (We've worked quite a bit

Re: How to start a TaskManager and the Flink Query Interface from, Scala IDE (local run configuration)

2015-03-09 Thread Robert Metzger
Mh. Thats weird. It looks like your JobManager is being started in the cluster mode. Can you pull the latest changes from master? (We've worked quite a bit on exactly the startup and logging behavior of the JM / TM). Usually, there should be a message like: 21:10:22,652 INFO org.apache.flink.run

Re: How to start a TaskManager and the Flink Query Interface from, Scala IDE (local run configuration)

2015-03-09 Thread Mihail Vieru
Hi, thank you for your answer. The JobManager web interface aka Flink Dashboard is accessible. I see, but there is a *ProgramInvocationException* thrown and the job fails when I submit the WordCount job through the CLI: Caused by: org.apache.flink.runtime.jobmanager.scheduler.*NoResourceAv

Re: How to start a TaskManager and the Flink Query Interface from, Scala IDE (local run configuration)

2015-03-09 Thread Robert Metzger
Hi, this looks actually quite good. Is the JobManager web interface accessible on port 8081 ? With the exec mode set " --executionMode LOCAL" there is no explicit start of a TaskManager required. Its running in the same JVM as the JobManager. The Flink Query Interface needs to be started using an