Flink1.32 akka.tcp
启动集群时，TaskManager中的日志如下所示：
INFO org.apache.flink.runtime.taskmanager.TaskManager -试图在JobManager akka.tcp://flink@master1 1:6123/user/作业管理器注册(尝试1，超时时间: 500毫秒) INFO org.apache.flink.runtime.taskmanager.TaskManager -试图在JobManager akka.tcp://flink@master1 1:6123/user/作业管理器注册(尝试2，超时: 1000毫秒) INFO org.apache.flink.runtime.taskmanager.TaskManager --试图在JobManager akka.tcp://flink@master1 1:6123/user/作业管理器注册(尝试3，超时时间: 2000毫秒) INFO org.apache.flink.runtime.taskmanager.TaskManager -试图在JobManager akka.tcp://flink@master1 1:6123/user/作业管理器注册(尝试4，超时: 8000毫秒) INFO org.apache.flink.runtime.taskmanager.TaskManager --试图在JobManager akka.tcp://flink@master1 1:6123/user/作业管理器注册(尝试5次，超时时间: 16000毫秒) INFO org.apache.flink.runtime.taskmanager.TaskManager --试图在JobManager akka.tcp://flink@master1 1:6123/user/作业管理器注册(尝试6次，超时时间: 30000毫秒) INFO org.apache.flink.runtime.taskmanager.TaskManager --试图在JobManager akka.tcp://flink@master1 1:6123/user/作业管理器注册(尝试7次，超时时间: 30000毫秒) INFO org.apache.flink.runtime.taskmanager.TaskManager --试图在JobManager akka.tcp://flink@master1 1:6123/user/作业管理器注册(尝试8次，超时时间: 30000毫秒) INFO org.apache.flink.runtime.taskmanager.TaskManager --试图在JobManager akka.tcp://flink@master1 1:6123/user/作业管理器注册(尝试9次，超时时间: 30000毫秒) INFO org.apache.flink.runtime.taskmanager.TaskManager --试图在JobManager akka.tcp://flink@master1 1:6123/user/作业管理器注册(尝试10次，超时时间: 30000毫秒)
它似乎无法与JobManger连接，Bu网络用户可以看到TaskManager。当我向集群提交作业时，JobManager得到一些错误日志：
由:akka.pattern.AskTimeoutException:Recipient[Actorakka://flink/deadLetters]引起的已被终止
我想akka犯了一些错误，但我不知道如何解决。非常感谢你帮助我
回答 1
Stack Overflow用户
发布于 2018-03-22 09:00:48
最后，我自己解决了这个问题。flink 1.3.x上有一个错误，您的集群主机不能包含特殊字符。
在我的生产环境中，主机被称为"flink_master“"slaves_01”"slaves_02“。"_“引起了这个问题。似乎您只允许使用字母、数字和数字字符。当我将主机更改为"master“"salves1”"slaves2“时，效果很好。
https://stackoverflow.com/questions/49399834
复制相似问题
腾讯云开发者
