When I start my flink job I get the following warning, if I am not wrong this is because it can't find the jobmanager at the given address(localhost), I tried changing:
config.setString(JobManagerOptions.ADDRESS, "localhost"); to LAN IP, 127.0.0.1 and localhost but none of it seems to work. I am not really sure what I am doing wrong here. 2017-08-02 17:20:26,137 INFO [Remoting] - Remoting started; listening on addresses :[akka.tcp://flink@169.254.65.27:53923] 2017-08-02 17:20:26,140 INFO [Remoting] - Remoting started; listening on addresses :[akka.tcp://flink@169.254.65.27:53920] 2017-08-02 17:20:26,154 INFO [Remoting] - Remoting started; listening on addresses :[akka.tcp://flink@169.254.65.27:53921] 2017-08-02 17:20:26,163 INFO [Remoting] - Remoting started; listening on addresses :[akka.tcp://flink@169.254.65.27:53922] 2017-08-02 17:20:26,166 INFO [AbstractCoordinator] - Discovered coordinator airpluspoc-hdp-dn0.germanycentral.cloudapp.microsoftazure.de:9092 (id: 2147482644 rack: null) for group flink-dqm. 2017-08-02 17:20:27,493 WARN [ReliableDeliverySupervisor] - Association with remote system [akka.tcp://flink@localhost:6123] has failed, address is now gated for [5000] ms. Reason: [Association failed with [akka.tcp://flink@localhost:6123]] Caused by: [Connection refused: no further information] 2017-08-02 17:20:27,493 WARN [ReliableDeliverySupervisor] - Association with remote system [akka.tcp://flink@localhost:6123] has failed, address is now gated for [5000] ms. Reason: [Association failed with [akka.tcp://flink@localhost:6123]] Caused by: [Connection refused: no further information] 2017-08-02 17:20:27,493 WARN [ReliableDeliverySupervisor] - Association with remote system [akka.tcp://flink@localhost:6123] has failed, address is now gated for [5000] ms. Reason: [Association failed with [akka.tcp://flink@localhost:6123]] Caused by: [Connection refused: no further information] 2017-08-02 17:20:27,493 WARN [ReliableDeliverySupervisor] - Association with remote system [akka.tcp://flink@localhost:6123] has failed, address is now gated for [5000] ms. Reason: [Association failed with [akka.tcp://flink@localhost:6123]] Caused by: [Connection refused: no further information] and then it fails while accessing the queryable state with the following error: akka.actor.ActorNotFound: Actor not found for: ActorSelection[Anchor(akka.tcp://flink@localhost:6123/), Path(/user/jobmanager)] Also, I wanted to check the jobmanager UI and for this I set up my job as follows: Configuration conf = new Configuration(); conf.setBoolean(ConfigConstants.LOCAL_START_WEBSERVER, true); StreamExecutionEnvironment env = LocalStreamEnvironment.createLocalEnvironmentWithWebUI(conf); and I couldn't even access the flink UI at localhost:8081 and other addresses as well. What would be the best way to find and access the jobmanager address and UI? Thanks and Regards Biplob -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Can-t-find-correct-JobManager-address-job-fails-with-Queryable-state-tp14644.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.