flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Stephan Ewen <se...@apache.org>
Subject Re: Could not build up connection to JobManager
Date Sat, 14 Mar 2015 15:42:39 GMT
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.me@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 <trohrmann@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.me@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]
>
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message