The log says: Unable to allocate on port 6123, due to error: Cannot assign requested address
Thus, I would assume that something with your cluster configuration is not entirely correct. Could you check that? On Thu, Apr 14, 2016 at 11:19 AM, ned dogg <neddog...@gmail.com> wrote: > Here a try that I given. As first I was configuring my cluster with private > ip and it was starting properly. > So to avoid this akka issue, I decided to configure my cluster with public > address but with this configuration, my cluster is not starting at all. > Here is the logs that I get > 2016-04-14 09:08:52,845 INFO > org.apache.flink.runtime.jobmanager.JobManager - > > -------------------------------------------------------------------------------- > 2016-04-14 09:08:52,847 INFO > org.apache.flink.runtime.jobmanager.JobManager - Starting > JobManager (Version: 1.0.1, Rev:4afa401, Date:31.03.2016 @ 13:40:33 UTC) > 2016-04-14 09:08:52,847 INFO > org.apache.flink.runtime.jobmanager.JobManager - Current > user: ubuntu > 2016-04-14 09:08:52,847 INFO > org.apache.flink.runtime.jobmanager.JobManager - JVM: > OpenJDK 64-Bit Server VM - Oracle Corporation - 1.7/24.95-b01 > 2016-04-14 09:08:52,847 INFO > org.apache.flink.runtime.jobmanager.JobManager - Maximum > heap size: 247 MiBytes > 2016-04-14 09:08:52,847 INFO > org.apache.flink.runtime.jobmanager.JobManager - > JAVA_HOME: (not set) > 2016-04-14 09:08:52,880 INFO > org.apache.flink.runtime.jobmanager.JobManager - Hadoop > version: 1.2.1 > 2016-04-14 09:08:52,881 INFO > org.apache.flink.runtime.jobmanager.JobManager - JVM > Options: > 2016-04-14 09:08:52,881 INFO > org.apache.flink.runtime.jobmanager.JobManager - > -Xms256m > 2016-04-14 09:08:52,881 INFO > org.apache.flink.runtime.jobmanager.JobManager - > -Xmx256m > 2016-04-14 09:08:52,881 INFO > org.apache.flink.runtime.jobmanager.JobManager - > -XX:MaxPermSize=256m > 2016-04-14 09:08:52,881 INFO > org.apache.flink.runtime.jobmanager.JobManager - > > -Dlog.file=/home/ubuntu/flink/log/flink-ubuntu-jobmanager-1-tresor-thiswithpublicip.479319055.streamly.com.log > 2016-04-14 09:08:52,881 INFO > org.apache.flink.runtime.jobmanager.JobManager - > -Dlog4j.configuration=file:/home/ubuntu/flink/conf/log4j.properties > 2016-04-14 09:08:52,881 INFO > org.apache.flink.runtime.jobmanager.JobManager - > -Dlogback.configurationFile=file:/home/ubuntu/flink/conf/logback.xml > 2016-04-14 09:08:52,881 INFO > org.apache.flink.runtime.jobmanager.JobManager - Program > Arguments: > 2016-04-14 09:08:52,881 INFO > org.apache.flink.runtime.jobmanager.JobManager - > --configDir > 2016-04-14 09:08:52,881 INFO > org.apache.flink.runtime.jobmanager.JobManager - > /home/ubuntu/flink/conf > 2016-04-14 09:08:52,881 INFO > org.apache.flink.runtime.jobmanager.JobManager - > --executionMode > 2016-04-14 09:08:52,881 INFO > org.apache.flink.runtime.jobmanager.JobManager - > cluster > 2016-04-14 09:08:52,881 INFO > org.apache.flink.runtime.jobmanager.JobManager - > Classpath: > > /home/ubuntu/flink/lib/flink-dist_2.10-1.0.1.jar:/home/ubuntu/flink/lib/flink-python_2.10-1.0.1.jar:/home/ubuntu/flink/lib/log4j-1.2.17.jar:/home/ubuntu/flink/lib/slf4j-log4j12-1.7.7.jar::: > 2016-04-14 09:08:52,882 INFO > org.apache.flink.runtime.jobmanager.JobManager - > > -------------------------------------------------------------------------------- > 2016-04-14 09:08:52,883 INFO > org.apache.flink.runtime.jobmanager.JobManager - Registered > UNIX signal handlers for [TERM, HUP, INT] > 2016-04-14 09:08:53,324 INFO > org.apache.flink.runtime.jobmanager.JobManager - Loading > configuration from /home/ubuntu/flink/conf > 2016-04-14 09:08:53,373 INFO > org.apache.flink.runtime.jobmanager.JobManager - Starting > JobManager without high-availability > 2016-04-14 09:08:53,390 INFO > org.apache.flink.runtime.jobmanager.JobManager - Starting > JobManager on 54.233.145.230:6123 with execution mode CLUSTER > 2016-04-14 09:08:53,613 INFO > org.apache.flink.runtime.jobmanager.JobManager - Security > is not enabled. Starting non-authenticated JobManager. > 2016-04-14 09:08:53,651 INFO org.apache.flink.util.NetUtils > - Unable to allocate on port 6123, due to error: Cannot > assign requested address > 2016-04-14 09:08:53,654 ERROR > org.apache.flink.runtime.jobmanager.JobManager - Failed to > run JobManager. > java.lang.RuntimeException: Unable to do further retries starting the actor > system > at > > org.apache.flink.runtime.jobmanager.JobManager$.retryOnBindException(JobManager.scala:1779) > at > > org.apache.flink.runtime.jobmanager.JobManager$.runJobManager(JobManager.scala:1719) > at > org.apache.flink.runtime.jobmanager.JobManager$.main(JobManager.scala:1655) > at org.apache.flink.runtime.jobmanager.JobManager.main(JobManager.scala) > > > > On Thu, Apr 14, 2016 at 10:11 AM, ned dogg <neddog...@gmail.com> wrote: > > > Thanks Till for the reply. > > > > But according to you how can I address that? > > > > Thanks, > > Ned > > > > On Thu, Apr 14, 2016 at 9:56 AM, Till Rohrmann <till.rohrm...@gmail.com> > > wrote: > > > >> Hi Ned, > >> > >> I think you are facing the issue described in this JIRA issue [1]. The > >> problem is that you have a private and a public IP address and that Akka > >> binds to the private IP address. Since the registered IP of an > ActorSystem > >> and the target IP address of a request to this ActorSystem have to be > >> matching, you cannot reach the ActorSystem via the public IP address. > >> Requests with a non-matching IP address are discarded, as indicated by > the > >> last log statements. > >> > >> [1] https://issues.apache.org/jira/browse/FLINK-2821 > >> > >> Cheers, > >> Till > >> > >> On Thu, Apr 14, 2016 at 10:41 AM, ned dogg <neddog...@gmail.com> wrote: > >> > >> > 2016-04-14 08:23:51,900 INFO > >> > org.apache.flink.runtime.jobmanager.JobManager - > >> > > >> > > >> > -------------------------------------------------------------------------------- > >> > 2016-04-14 08:23:51,902 INFO > >> > org.apache.flink.runtime.jobmanager.JobManager - > >> Starting > >> > JobManager (Version: 1.0.1, Rev:4afa401, Date:31.03.2016 @ 13:40:33 > UTC) > >> > 2016-04-14 08:23:51,902 INFO > >> > org.apache.flink.runtime.jobmanager.JobManager - > >> Current > >> > user: root > >> > 2016-04-14 08:23:51,902 INFO > >> > org.apache.flink.runtime.jobmanager.JobManager - JVM: > >> > OpenJDK 64-Bit Server VM - Oracle Corporation - 1.7/24.95-b01 > >> > 2016-04-14 08:23:51,902 INFO > >> > org.apache.flink.runtime.jobmanager.JobManager - > >> Maximum > >> > heap size: 247 MiBytes > >> > 2016-04-14 08:23:51,902 INFO > >> > org.apache.flink.runtime.jobmanager.JobManager - > >> > JAVA_HOME: /usr/lib/jvm/java-7-openjdk-amd64 > >> > 2016-04-14 08:23:51,929 INFO > >> > org.apache.flink.runtime.jobmanager.JobManager - > Hadoop > >> > version: 1.2.1 > >> > 2016-04-14 08:23:51,929 INFO > >> > org.apache.flink.runtime.jobmanager.JobManager - JVM > >> > Options: > >> > 2016-04-14 08:23:51,930 INFO > >> > org.apache.flink.runtime.jobmanager.JobManager - > >> > -Xms256m > >> > 2016-04-14 08:23:51,930 INFO > >> > org.apache.flink.runtime.jobmanager.JobManager - > >> > -Xmx256m > >> > 2016-04-14 08:23:51,930 INFO > >> > org.apache.flink.runtime.jobmanager.JobManager - > >> > -XX:MaxPermSize=256m > >> > 2016-04-14 08:23:51,930 INFO > >> > org.apache.flink.runtime.jobmanager.JobManager - > >> > > >> > > >> > -Dlog.file=/home/ubuntu/flink/log/flink-root-jobmanager-0-tresor-testflinkth.1541841583.streamly.com.log > >> > 2016-04-14 08:23:51,930 INFO > >> > org.apache.flink.runtime.jobmanager.JobManager - > >> > -Dlog4j.configuration=file:/home/ubuntu/flink/conf/log4j.properties > >> > 2016-04-14 08:23:51,930 INFO > >> > org.apache.flink.runtime.jobmanager.JobManager - > >> > -Dlogback.configurationFile=file:/home/ubuntu/flink/conf/logback.xml > >> > 2016-04-14 08:23:51,930 INFO > >> > org.apache.flink.runtime.jobmanager.JobManager - > >> Program > >> > Arguments: > >> > 2016-04-14 08:23:51,930 INFO > >> > org.apache.flink.runtime.jobmanager.JobManager - > >> > --configDir > >> > 2016-04-14 08:23:51,930 INFO > >> > org.apache.flink.runtime.jobmanager.JobManager - > >> > /home/ubuntu/flink/conf > >> > 2016-04-14 08:23:51,930 INFO > >> > org.apache.flink.runtime.jobmanager.JobManager - > >> > --executionMode > >> > 2016-04-14 08:23:51,930 INFO > >> > org.apache.flink.runtime.jobmanager.JobManager - > >> > cluster > >> > 2016-04-14 08:23:51,930 INFO > >> > org.apache.flink.runtime.jobmanager.JobManager - > >> > Classpath: > >> > > >> > > >> > /home/ubuntu/flink/lib/flink-dist_2.10-1.0.1.jar:/home/ubuntu/flink/lib/flink-python_2.10-1.0.1.jar:/home/ubuntu/flink/lib/log4j-1.2.17.jar:/home/ubuntu/flink/lib/slf4j-log4j12-1.7.7.jar::: > >> > 2016-04-14 08:23:51,930 INFO > >> > org.apache.flink.runtime.jobmanager.JobManager - > >> > > >> > > >> > -------------------------------------------------------------------------------- > >> > 2016-04-14 08:23:51,931 INFO > >> > org.apache.flink.runtime.jobmanager.JobManager - > >> Registered > >> > UNIX signal handlers for [TERM, HUP, INT] > >> > 2016-04-14 08:23:52,362 INFO > >> > org.apache.flink.runtime.jobmanager.JobManager - > Loading > >> > configuration from /home/ubuntu/flink/conf > >> > 2016-04-14 08:23:52,400 INFO > >> > org.apache.flink.runtime.jobmanager.JobManager - > >> Starting > >> > JobManager without high-availability > >> > 2016-04-14 08:23:52,408 INFO > >> > org.apache.flink.runtime.jobmanager.JobManager - > >> Starting > >> > JobManager on 172.31.45.232:6123 with execution mode CLUSTER > >> > 2016-04-14 08:23:52,655 INFO > >> > org.apache.flink.runtime.jobmanager.JobManager - > >> Security > >> > is not enabled. Starting non-authenticated JobManager. > >> > 2016-04-14 08:23:52,701 INFO > >> > org.apache.flink.runtime.jobmanager.JobManager - > >> Starting > >> > JobManager > >> > 2016-04-14 08:23:52,701 INFO > >> > org.apache.flink.runtime.jobmanager.JobManager - > >> Starting > >> > JobManager actor system at 172.31.45.232:6123 > >> > 2016-04-14 08:23:54,091 INFO akka.event.slf4j.Slf4jLogger > >> > - Slf4jLogger started > >> > 2016-04-14 08:23:54,293 INFO Remoting > >> > - Starting remoting > >> > 2016-04-14 08:23:54,712 INFO Remoting > >> > - Remoting started; listening on addresses > >> :[akka.tcp:// > >> > flink@172.31.45.232:6123] > >> > 2016-04-14 08:23:54,732 INFO > >> > org.apache.flink.runtime.jobmanager.JobManager - > >> Starting > >> > JobManger web frontend > >> > 2016-04-14 08:23:54,777 INFO > >> > org.apache.flink.runtime.webmonitor.WebMonitorUtils - > >> Determined > >> > location of JobManager log file: > >> > > >> > > >> > /home/ubuntu/flink/log/flink-root-jobmanager-0-tresor-testflinkth.1541841583.streamly.com.log > >> > 2016-04-14 08:23:54,777 INFO > >> > org.apache.flink.runtime.webmonitor.WebMonitorUtils - > >> Determined > >> > location of JobManager stdout file: > >> > > >> > > >> > /home/ubuntu/flink/log/flink-root-jobmanager-0-tresor-testflinkth.1541841583.streamly.com.out > >> > 2016-04-14 08:23:54,805 INFO > >> > org.apache.flink.runtime.webmonitor.WebRuntimeMonitor - Using > >> > directory /tmp/flink-web-dadb12c4-4ac9-42d6-b127-712db44b4add for the > >> web > >> > interface files > >> > 2016-04-14 08:23:54,805 INFO > >> > org.apache.flink.runtime.webmonitor.WebRuntimeMonitor - Using > >> > directory /tmp/flink-web-upload-88dc8823-f114-4787-a6f4-f1955380e384 > for > >> > web frontend JAR file uploads > >> > 2016-04-14 08:23:55,600 INFO > >> > org.apache.flink.runtime.webmonitor.WebRuntimeMonitor - Web > >> > frontend listening at 0:0:0:0:0:0:0:0:8081 > >> > 2016-04-14 08:23:55,601 INFO > >> > org.apache.flink.runtime.jobmanager.JobManager - > >> Starting > >> > JobManager actor > >> > 2016-04-14 08:23:55,619 INFO org.apache.flink.runtime.blob.BlobServer > >> > - Created BLOB server storage directory > >> > /tmp/blobStore-bbc7f33e-fa65-41f8-8c68-549e9707fd56 > >> > 2016-04-14 08:23:55,634 INFO org.apache.flink.runtime.blob.BlobServer > >> > - Started BLOB server at 0.0.0.0:60439 - max > >> concurrent > >> > requests: 50 - max backlog: 1000 > >> > 2016-04-14 08:23:55,653 INFO > >> > org.apache.flink.runtime.checkpoint.SavepointStoreFactory - Using > >> job > >> > manager savepoint state backend. > >> > 2016-04-14 08:23:55,678 INFO > >> > org.apache.flink.runtime.webmonitor.WebRuntimeMonitor - > >> Starting > >> > with JobManager akka.tcp://flink@172.31.45.232:6123/user/jobmanager > on > >> > port > >> > 8081 > >> > 2016-04-14 08:23:55,678 INFO > >> > org.apache.flink.runtime.webmonitor.JobManagerRetriever - New > >> leader > >> > reachable under akka.tcp:// > >> flink@172.31.45.232:6123/user/jobmanager:null. > >> > 2016-04-14 08:23:55,692 INFO > >> > org.apache.flink.runtime.jobmanager.JobManager - > >> Starting > >> > JobManager at akka.tcp://flink@172.31.45.232:6123/user/jobmanager. > >> > 2016-04-14 08:23:55,696 INFO > >> > org.apache.flink.runtime.jobmanager.MemoryArchivist - > Started > >> > memory archivist akka://flink/user/archive > >> > 2016-04-14 08:23:55,702 INFO > >> > org.apache.flink.runtime.jobmanager.JobManager - > >> JobManager > >> > akka.tcp://flink@172.31.45.232:6123/user/jobmanager was granted > >> leadership > >> > with leader session ID None. > >> > 2016-04-14 08:24:12,740 INFO > >> > org.apache.flink.runtime.instance.InstanceManager - > >> Registered > >> > TaskManager at tresor-testflinkth (akka.tcp:// > >> > flink@172.31.45.130:42189/user/taskmanager) as > >> > 734b6b21dd60760c7a05722db3c3d1c4. Current number of registered hosts > is > >> 1. > >> > Current number of alive task slots is 1. > >> > 2016-04-14 08:24:17,855 INFO > >> > org.apache.flink.runtime.instance.InstanceManager - > >> Registered > >> > TaskManager at tresor-testflinkth (akka.tcp:// > >> > flink@172.31.34.121:58814/user/taskmanager) as > >> > fead50f6831aa3f341d58162bb918d90. Current number of registered hosts > is > >> 2. > >> > Current number of alive task slots is 2. > >> > 2016-04-14 08:29:50,346 ERROR akka.remote.EndpointWriter > >> > - dropping message [class > >> > akka.actor.ActorSelectionMessage] for non-local recipient > >> > [Actor[akka.tcp:// > >> > flink@54.233.183.228:6123/]] arriving at [akka.tcp:// > >> > flink@54.233.183.228:6123] inbound addresses are [akka.tcp:// > >> > flink@172.31.45.232:6123] > >> > 2016-04-14 08:29:59,777 WARN akka.remote.ReliableDeliverySupervisor > >> > - Association with remote system [akka.tcp:// > >> > flink@127.0.0.1:35953] has failed, address is now gated for [5000] > ms. > >> > Reason is: [Disassociated]. > >> > > >> > > >> > Where 54.233.183.228 <http://flink@54.233.183.228:6123> is the public > >> > address of the VM hosting job manager and 172.31.45.232 > >> > <http://flink@172.31.45.232:6123> is it private address. > >> > 172.31.45.130 <http://flink@172.31.45.130:42189/user/taskmanager> and > >> > 172.31.34.121 <http://flink@172.31.34.121:58814/user/taskmanager> are > >> the > >> > private address of the task manager > >> > > >> > On Thu, Apr 14, 2016 at 9:05 AM, Till Rohrmann <trohrm...@apache.org> > >> > wrote: > >> > > >> > > 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 > >> > > > > > > >> > > > > > >> > > > > >> > > > >> > > >> > > > > >
