I'm referring to the jobmanager.log file not the client log file. You can find it in the `/log` directory.
Cheers, Till On Thu, Apr 14, 2016 at 9:56 AM, ned dogg <neddog...@gmail.com> wrote: > Hi Till > > Thanks for the prompt reply. > > The logs say that Please make sure that the actor is running and its port > is reachable. > And it is actaully reachable because I can ping that address. > > Ned. > > On Thu, Apr 14, 2016 at 8:43 AM, Till Rohrmann <till.rohrm...@gmail.com> > wrote: > > > Hi Ned, > > > > what does the logs of the JobManager say? > > > > Cheers, > > Till > > On Apr 14, 2016 9:19 AM, "ned dogg" <neddog...@gmail.com> wrote: > > > > > Hi everybody, > > > > > > I'm Ned, a young and passionte developer of apache technologies. I have > > > been playing with apache flink lastly. > > > > > > This is what I wanted to do submit a flink topology to a remote flink > > > cluster. The following are the steps that I did. > > > > > > - Install flink as a cluster indicated on the link > > > > > > > > > https://ci.apache.org/projects/flink/flink-docs-master/setup/cluster_setup.html > > > on three remotes VMs. > > > - Run the sample WordCountRemoteByClient > > > < > > > > > > https://github.com/apache/flink/blob/master/flink-contrib/flink-storm-examples/src/main/java/org/apache/flink/storm/wordcount/WordCountRemoteByClient.java > > > > > > > by > > > changing > > > conf.put(Config.NIMBUS_HOST, "localhost"); to > > > conf.put(Config.NIMBUS_HOST, "publicIpOfJobmanagerInMyRemoteCluster"); > > > > > > Unfortunately for me when I run that program, I have a the following > > > exception. > > > > > > org.apache.flink.client.program.ProgramInvocationException: The main > > method > > > caused an error. > > > at > > > > > > > > > org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:520) > > > at > > > > > > > > > org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:403) > > > at org.apache.flink.client.program.Client.runBlocking(Client.java:248) > > > at > > > > > > > > > org.apache.flink.client.CliFrontend.executeProgramBlocking(CliFrontend.java:866) > > > at org.apache.flink.client.CliFrontend.run(CliFrontend.java:333) > > > at > > > > > > org.apache.flink.client.CliFrontend.parseParameters(CliFrontend.java:1189) > > > at org.apache.flink.client.CliFrontend.main(CliFrontend.java:1239) > > > Caused by: java.lang.RuntimeException: Could not connect to Flink > > > JobManager with address publicIpOfJobmanagerInMyRemoteCluster:6123 > > > at > > > > > > > > > org.apache.flink.storm.api.FlinkClient.getTopologyJobId(FlinkClient.java:305) > > > at > > > > > > > > > org.apache.flink.storm.api.FlinkClient.submitTopologyWithOpts(FlinkClient.java:177) > > > at > > > > > > org.apache.flink.storm.api.FlinkClient.submitTopology(FlinkClient.java:167) > > > at > > > > > > > > > stormWorldCount.WordCountRemoteByClient.main(WordCountRemoteByClient.java:72) > > > 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:505) > > > ... 6 more > > > Caused by: java.io.IOException: Actor at akka.tcp://flink@ > > > publicIpOfJobmanagerInMyRemoteCluster:6123/user/jobmanager not > reachable. > > > Please make sure that the actor is running and its port is reachable. > > > at > > > > org.apache.flink.runtime.akka.AkkaUtils$.getActorRef(AkkaUtils.scala:384) > > > at > > > > > > > > > org.apache.flink.runtime.jobmanager.JobManager$.getJobManagerActorRef(JobManager.scala:2380) > > > at > > > > > > > > > org.apache.flink.runtime.jobmanager.JobManager$.getJobManagerActorRef(JobManager.scala:2400) > > > at > > > > > > > > > org.apache.flink.runtime.jobmanager.JobManager.getJobManagerActorRef(JobManager.scala) > > > at > > > > > > org.apache.flink.storm.api.FlinkClient.getJobManager(FlinkClient.java:333) > > > at > > > > > > > > > org.apache.flink.storm.api.FlinkClient.getTopologyJobId(FlinkClient.java:279) > > > ... 14 more > > > Caused by: java.util.concurrent.TimeoutException: Futures timed out > after > > > [10000 milliseconds] > > > at > scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:219) > > > at > scala.concurrent.impl.Promise$DefaultPromise.result(Promise.scala:223) > > > at scala.concurrent.Await$$anonfun$result$1.apply(package.scala:107) > > > at > > > > > > > > > scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:53) > > > at scala.concurrent.Await$.result(package.scala:107) > > > at > > > > org.apache.flink.runtime.akka.AkkaUtils$.getActorRef(AkkaUtils.scala:380) > > > ... 19 more > > > > > > I try ping my jobmanager with > > > curl publicIpOfJobmanagerInMyRemoteCluster:6123 I had the following as > > > responces. > > > > > > curl: (52) Empty reply from server > > > > > > Which is an indication that the job manager is reachable. > > > > > > So I was wondering if I doing it the right way. Please any help will be > > > welcoming. > > > > > > Thanks, > > > Ned > > > > > >
