Hay Stephan, Great to know you could fix the issue. Thank you on the update. Best regards.
> On Mar 14, 2015, at 9:19 PM, Stephan Ewen <se...@apache.org> wrote: > > Hey Dulaj! > > Forget what I said in the previous email. The issue with the wrong address > binding seems to be solved now. There is another issue that the embedded > taskmanager does not start properly, for whatever reason. My gut feeling is > that there is something wrong > > There is a patch pending that changes the startup behavior to debug these > situations much easier. I'll ping you as soon as that is in... > > > Stephan > > On Sat, Mar 14, 2015 at 4:42 PM, Stephan Ewen <se...@apache.org> wrote: > >> 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] >>> >>> >>
