OSDir


[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

is there a config to ask taskmanager to keep retrying connect to jobmanager after Disassociated?


I depoloy a standard alone cluster with flink1.5 and when I try to restart
the only jobmanger, below is the log print from task manager:
2018-06-04 12:06:35,882 WARN  akka.remote.ReliableDeliverySupervisor                       
- Association with remote system [akka.tcp://flink@ipaddress:6123] has
failed, address is now gated for [50] ms. Reason: [Disassociated]
2018-06-04 12:07:17,580 INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor            - The
heartbeat of ResourceManager with id 6af9bbb514a6ddaeca95d6e52db6dbd5 timed
out.
2018-06-04 12:07:17,580 INFO 
org.apache.flink.runtime.taskexecutor.TaskExecutor            - Close
ResourceManager connection 6af9bbb514a6ddaeca95d6e52db6dbd5.
2018-06-04 12:07:17,611 WARN  akka.remote.transport.netty.NettyTransport                   
- Remote connection to [null] failed with java.net.ConnectException:
Connection refused: /ipaddress:6123
2018-06-04 12:07:17,611 WARN  akka.remote.ReliableDeliverySupervisor                       
- Association with remote system [akka.tcp://flink@ipaddress:6123] has
failed, address is now gated for [50] ms. Reason: [Association failed with
[akka.tcp://flink@ipaddress:6123]] Caused by: [Connection refused:
/ipaddress:6123]

so I'd like to know if there is a config to ask task manager to keep
retrying to connect to job manager(since I am restating jobmanager so it
will come back later)?



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/