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.
