Flink TaskManager未重新连接到新的Jobmanager
我在HA模式下配置了Flink，如下所述：
我想测试容错性，因此我做了以下工作：
- 设置具有2个JobManager和1个TaskManager的Flink群集
- 在任务管理器上启动流式处理作业
- 杀死活动的作业管理器（以模拟崩溃）
- 领导人选举如期举行
- 但注意到任务管理器正在重新连接到新的作业管理器。它只是每10秒尝试重新连接到前一个领导者
在此处粘贴任务管理器日志：
2018-07-25 19:46:08,508 INFO org.apache.flink.runtime.taskexecutor.TaskManagerConfiguration - Messages have a max timeout of 10000 ms
2018-07-25 19:46:08,515 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for org.apache.flink.runtime.taskexecutor.TaskExecutor at akka://flink/user/taskmanager_0 .
2018-07-25 19:46:08,524 INFO org.apache.flink.runtime.leaderretrieval.ZooKeeperLeaderRetrievalService - Starting ZooKeeperLeaderRetrievalService /leader/resource_manager_lock.
2018-07-25 19:46:08,525 INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Start job leader service.
2018-07-25 19:46:08,529 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Connecting to ResourceManager akka.tcp://flink@10.10.97.210:46477/user/resourcemanager(b91b9aeb3565be973c9bb47259414e0a).
2018-07-25 19:46:08,574 WARN akka.remote.transport.netty.NettyTransport - Remote connection to [null] failed with java.net.ConnectException: Connection refused: /10.10.97.210:46477
2018-07-25 19:46:08,576 WARN akka.remote.ReliableDeliverySupervisor - Association with remote system [akka.tcp://flink@10.10.97.210:46477] has failed, address is now gated for [50] ms. Reason: [Association failed with [akka.tcp://flink@10.10.97.210:46477]] Caused by: [Connection refused: /10.10.97.210:46477]
2018-07-25 19:46:08,579 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Could not resolve ResourceManager address akka.tcp://flink@10.10.97.210:46477/user/resourcemanager, retrying in 10000 ms: Could not connect to rpc endpoint under address akka.tcp://flink@10.10.97.210:46477/user/resourcemanager..
2018-07-25 19:46:18,606 WARN akka.remote.transport.netty.NettyTransport - Remote connection to [null] failed with java.net.ConnectException: Connection refused: /10.10.97.210:46477
2018-07-25 19:46:18,607 WARN akka.remote.ReliableDeliverySupervisor - Association with remote system [akka.tcp://flink@10.10.97.210:46477] has failed, address is now gated for [50] ms. Reason: [Association failed with [akka.tcp://flink@10.10.97.210:46477]] Caused by: [Connection refused: /10.10.97.210:46477]
2018-07-25 19:46:18,607 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Could not resolve ResourceManager address akka.tcp://flink@10.10.97.210:46477/user/resourcemanager, retrying in 10000 ms: Could not connect to rpc endpoint under address akka.tcp://flink@10.10.97.210:46477/user/resourcemanager..
- 重新启动任务管理器没有帮助
- 重新启动群集没有帮助
如果缺少什么，请指导我。
共有1个答案
查看日志：
拒绝连接：/10.10.97.210:46477
端口46477是否已打开/从防火墙中排除？
只需检查您是否在flink配置中设置了以下内容：
jobmanager.rpc.port: 6123
blob.server.port: 50100-50200
然后解锁这些端口。
-
重新建立mqtt连接，前提是必须已经通过Iot_id，Iot_pwd建立过一次mqtt连接。 请求方式： "|4|1|5|\r" 返回值： "|4|1|1|1|\r" mqtt连接状态：连接成功 "|4|1|1|2|reason|\r" mqtt连接状态：连接失败，字符串reason表示失败的原因 Arduino样例： softSerial.print("|4|1|5|\r");
-
重新连接上一次连接的wifi。 请求方式： "|2|3|\r" 返回值： "|2|1|\r" wifi连接状态：wifi断开连接 "|2|2|\r" wifi连接状态：正在连接wifi "|2|3|ip|\r" wifi连接状态：wifi连接成功，返回OBLOQ的ip地址 "|2|4|\r" wifi连接状态：wifi连接失败，检查SSID和PWD是否输入正确 Arduino样例： softSer
-
问题内容： 更新： 我在驱动程序上使用2.1版本，而不是3.2 我有一个使用MongoDB的节点应用程序。我的问题是，如果MongoDB服务器由于任何原因而关闭，则应用程序不会重新连接。为了实现这一点，我基于此官方教程中的代码进行了测试。 想法是运行此脚本，然后停止mongod，然后重新启动它。所以，我们开始： 将MongoDb停止10秒钟可以达到预期效果：它将停止运行查询10秒钟，然后在服务器返
-
问题内容： 调用一次后如何重新连接到套接字io ？ 这是代码 如果我这样做，它会起作用。如果我这样做，它将断开连接。但是，如果我尝试使用重新连接，则连接不再起作用。我如何才能建立连接？ 问题答案： 好吧，您可以在这里选择… 首次初始化套接字值时，应使用， 下次（调用一次断开连接后），您应使用再次连接。 所以你的应该是这样的
-
问题内容： 在生产中，我有一个使用连接局部变量保存游戏状态的游戏。但是，我注意到，如果我在连接上闲置了一段时间，它将断开连接并重新连接，这将丢失当前状态。在本地主机上进行测试时，我从未注意到此行为。这是套接字连接的规范行为，还是导致连接断开的其他原因。 如果是正常行为，通常如何处理？是否应该将连接值全局存储，以便用户断开/重新连接时可以恢复连接值？ 问题答案： 您的问题与套接字超时有关。如果某个套
-
问题内容： 我们有一个Java侦听器，它从JBossMQ的队列中读取文本消息。如果必须重新启动JBoss，则侦听器将不会重新连接并重新开始阅读消息。我们只是每2分钟在侦听器的日志文件中收到一条消息，指出该消息无法连接。我们在代码或JBossMQ中没有设置什么吗？我是JMS的新手，因此将非常感谢您的帮助。谢谢。 问题答案： 您应该在客户端代码中实现javax.jms.ExceptionListene