Hi Rashmi,

The issue is that although you have a JobManager running (the master
component of a Flink cluster scheduling the jobs) there are no TaskManagers
running (the components doing the actual work). Hence you got the log
line "Resources available to scheduler: Number of instances=0, total number
of slots=0, available slots=0".

My bet without further information would be that you have created this
cluster with bin/start-cluster.sh from the Flink binaries and the
TaskManager did not start up. You can check both the TaskManager and
JobManager logs in the log/ directory if you want to investigate the issue.
Also it is worth to execute "jps" which lists the currently running Java
processes and their names to see whether you have both.

My suggestion for a local setup is to stop the cluster you are running
currently (bin/stop-cluster.sh) and start a local one instead with
bin/start-local.sh. This starts up the JobManager and a single TaskManager
in the same JVM. On a side note you can also run Flink programs from your
IDE with simply hitting Run, there is no need to fire up a cluster manually
unless you are testing the cluster itself.

Which cluster setup are you using?

Best,

Marton

On Sat, Oct 8, 2016 at 9:24 PM, Rashmi Varma <rshm.va...@gmail.com> wrote:

> Hello,
>
> I am trying to setup flink project on my local machine and I have been
> trying to run flink example codes but I keep getting '
> NoResourceAvailablleException".
>
> Please find the stack trace here : http://pastebin.com/NgPfnQck
>
> --
> Thanks,
> Rashmi
>

Reply via email to