Hey Dulaj! One thing you can try is to add to the JVM startup options (in the scripts in the "bin" folder) the option "-Djava.net.preferIPv4Stack=true" and see if that helps it?
Stephan On Sat, Mar 14, 2015 at 4:29 AM, Dulaj Viduranga <vidura...@icloud.com> wrote: > 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] > >
