flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Till Rohrmann <trohrm...@apache.org>
Subject Re: Could not build up connection to JobManager
Date Wed, 11 Mar 2015 18:02:52 GMT
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