Hi, can you have a look at the jobmanager log file in the "log/" directory? I suspect there was an issue when you've started the JobManager.
On Sun, Feb 22, 2015 at 4:35 PM, Dulaj Viduranga <[email protected]> wrote: > I tried to run an example program to the first time in FLINK and I got > this error. I have already started FLINK with bin/start-local.sh. Can > someone please help? > > 21:01:19,898 WARN org.apache.hadoop.util.NativeCodeLoader > - Unable to load native-hadoop library for your platform... using > builtin-java classes where applicable > org.apache.flink.client.program.ProgramInvocationException: Could not > build up connection to JobManager. > at org.apache.flink.client.program.Client.run(Client.java:327) > at org.apache.flink.client.program.Client.run(Client.java:306) > at org.apache.flink.client.program.Client.run(Client.java:300) > at > org.apache.flink.client.program.ContextEnvironment.execute(ContextEnvironment.java:55) > at > org.apache.flink.examples.java.wordcount.WordCount.main(WordCount.java:82) > at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) > at > sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) > at > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) > at java.lang.reflect.Method.invoke(Method.java:483) > at > org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:437) > at > org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:353) > at org.apache.flink.client.program.Client.run(Client.java:250) > at > org.apache.flink.client.CliFrontend.executeProgram(CliFrontend.java:371) > at org.apache.flink.client.CliFrontend.run(CliFrontend.java:344) > at > org.apache.flink.client.CliFrontend.parseParameters(CliFrontend.java:1087) > at org.apache.flink.client.CliFrontend.main(CliFrontend.java:1114) > Caused by: java.io.IOException: JobManager at akka.tcp:// > [email protected]:6123/user/jobmanager not reachable. Please make sure > that the JobManager is running and its port is reachable. > at > org.apache.flink.runtime.jobmanager.JobManager$.getJobManagerRemoteReference(JobManager.scala:897) > at > org.apache.flink.runtime.client.JobClient$.createJobClient(JobClient.scala:151) > at > org.apache.flink.runtime.client.JobClient$.createJobClientFromConfig(JobClient.scala:142) > at > org.apache.flink.runtime.client.JobClient$.startActorSystemAndActor(JobClient.scala:125) > at > org.apache.flink.runtime.client.JobClient.startActorSystemAndActor(JobClient.scala) > at org.apache.flink.client.program.Client.run(Client.java:322) > ... 15 more > Caused by: java.util.concurrent.TimeoutException: Futures timed out after > [10000 milliseconds] > at > scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:219) > at > scala.concurrent.impl.Promise$DefaultPromise.result(Promise.scala:223) > at > scala.concurrent.Await$$anonfun$result$1.apply(package.scala:107) > at > scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:53) > at scala.concurrent.Await$.result(package.scala:107) > at > org.apache.flink.runtime.jobmanager.JobManager$.getJobManagerRemoteReference(JobManager.scala:893) > ... 20 more > > The exception above occurred while trying to run your command.
