这个意思是 jobmanager 失联了么？
Association with remote system [akka.tcp://flink@flinkjobcluster-3b62e255-2ddf-4fbc-8722-012cc9d345e7-jobmanager:6123] has failed, address is now gated for [50] ms. Reason: [Association failed with [akka.tcp://flink@flinkjobcluster-3b62e255-2ddf-4fbc-8722-012cc9d345e7-jobmanager:6123]] Caused by: [java.net.ConnectException: Connection refused: flinkjobcluster-3b62e255-2ddf-4fbc-8722-012cc9d345e7-jobmanager/11.157.238.106:6123]
写回答
-
十分耕耘，一定会有一分收获！楼主你好，是的，这个报错提示说明 jobmanager 和 TaskManager 中的某个节点失去了联系，导致任务无法正常运行。可能是由于网络中断、节点宕机等原因导致的。需要检查集群节点的状态以及网络连接是否正常。
2023-07-31 09:33:32赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。
