Apache Flink:独立群集尝试使用用户名"flink“进行连接

Question

在我的硕士论文中，我尝试在4个节点上建立一个flink独立集群。我已经阅读了文档，该文档很好地解释了如何设置它。但是，当我启动集群时，会出现一个警告，当我尝试运行作业时，会出现错误，并显示相同的消息：

akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka.tcp://flink@MYHOSTNAME:6123/user/jobmanager#-818199108]] after [10000 ms]. Sender[null] sent message of type "org.apache.flink.runtime.messages.JobManagerMessages$LeaderSessionMessage"

增加超时不起作用。当我在web UI中打开任务管理器时，所有的任务管理器都有以下模式：

akka.tcp://flink@MYHOSTNAME:33779/user/taskmanager

有谁知道如何解决这个问题来让集群正常工作吗？提前感谢！

最后一件事:集群上没有用户"flink“，也不会被创建。所以任何没有告诉我应该创建该用户的建议都将非常感谢！谢谢!

Answer 1

不确定它是否仍然相关，但我使用的方式(使用Flink 1.5.3)：

我通过以下方式设置了一个包含3个主服务器(JobManager)和20个从服务器(TaskManager)的HA独立集群。

1. 定义您的conf/

文件(主机名:每行8081)

1. 定义您的conf/

文件(每行每个任务管理器的主机名)在flink-conf.yaml中定义

1. 在每个主计算机上的localhost
2. Once中它自己的jobmanager.rpc.address hostname
3. Define在每个从计算机上设置jobmanager.rpc.address时，在任何主主机上执行localhost
4. Once/
5. -
6. 。

如果您需要HA，那么您需要设置zookeeper quorum并修改关于HA的相应属性(高可用性、高可用性.storageDir、高可用性.zookeeper.quorum)