Hi, Still this is no luck. I’ll upload the logs with configuration “localhost" as well as “127.0.0.1” so you can take a look.
127.0.0.1 flink-Vidura-flink-client-localhost.log <https://gist.github.com/viduranga/1d01149eee238158519e#file-flink-vidura-flink-client-localhost-log> localhost flink-Vidura-flink-client-localhost.log <https://gist.github.com/viduranga/d866c24c0ba566abab17#file-flink-vidura-flink-client-localhost-log> flink-Vidura-jobmanager-localhost.log <https://gist.github.com/viduranga/e7549ef818c6a2af73e9#file-flink-vidura-jobmanager-localhost-log> > On Mar 11, 2015, at 11:32 PM, Till Rohrmann <trohrm...@apache.org> wrote: > > 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]
