Hi Dulaj, sorry for my late response. It looks as if the JobClient tries to connect to the JobManager using its IPv6 instead of IPv4. Akka is really picky when it comes to remote address. If Akka binds to the FQDN, then other ActorSystem which try to connect to it using its IP address won't be successful. I assume that this might be a problem. I tried to fix it. You can find it here [1]. Could you please try it out by starting a local cluster with the start-local.sh script. If it fails, could you please send me all log files (client, jobmanager and taskmanager). Once we figured out why the JobCilent does not connect, we can try to tackle the BlobServer issue.
Cheers, Till [1] https://github.com/tillrohrmann/flink/tree/fixJobClient On Thu, Mar 5, 2015 at 4:40 PM, Dulaj Viduranga <vidura...@icloud.com> wrote: > Hi, > The error message is, > > 21:06:01,521 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://flink@fe80:0:0:0:742b:7f78:fab5:68e2%11: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:957) > 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: akka.actor.ActorNotFound: Actor not found for: > ActorSelection[Anchor(akka://flink/deadLetters), Path(/)] > at > akka.actor.ActorSelection$$anonfun$resolveOne$1.apply(ActorSelection.scala:65) > at > akka.actor.ActorSelection$$anonfun$resolveOne$1.apply(ActorSelection.scala:63) > at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:32) > at > akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.processBatch$1(BatchingExecutor.scala:67) > at > akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.apply$mcV$sp(BatchingExecutor.scala:82) > at > akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.apply(BatchingExecutor.scala:59) > at > akka.dispatch.BatchingExecutor$Batch$$anonfun$run$1.apply(BatchingExecutor.scala:59) > at > scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:72) > at > akka.dispatch.BatchingExecutor$Batch.run(BatchingExecutor.scala:58) > at > akka.dispatch.ExecutionContexts$sameThreadExecutionContext$.unbatchedExecute(Future.scala:74) > at > akka.dispatch.BatchingExecutor$class.execute(BatchingExecutor.scala:110) > at > akka.dispatch.ExecutionContexts$sameThreadExecutionContext$.execute(Future.scala:73) > at > scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:40) > at > scala.concurrent.impl.Promise$DefaultPromise.scala$concurrent$impl$Promise$DefaultPromise$$dispatchOrAddCallback(Promise.scala:280) > at > scala.concurrent.impl.Promise$DefaultPromise.onComplete(Promise.scala:270) > at akka.actor.ActorSelection.resolveOne(ActorSelection.scala:63) > at > org.apache.flink.runtime.akka.AkkaUtils$.getReference(AkkaUtils.scala:321) > at > org.apache.flink.runtime.jobmanager.JobManager$.getJobManagerRemoteReference(JobManager.scala:952) > ... 20 more > > The exception above occurred while trying to run your command. > > > > > > Client log doesn’t seem to show any info, > > > 21:06:01,521 WARN org.apache.hadoop.util.NativeCodeLoader > - Unable to load native-hadoop library for your platform... using > builtin-java classes where applicable > 21:06:01,935 INFO org.apache.flink.api.java.ExecutionEnvironment > - The job has 0 registered types and 0 default Kryo serializers > 21:06:02,857 INFO akka.event.slf4j.Slf4jLogger > - Slf4jLogger started > 21:06:02,909 INFO Remoting > - Starting remoting > 21:06:03,158 INFO Remoting > - Remoting started; listening on addresses :[akka.tcp:// > flink@127.0.0.1:49463]
