我有一个 flink 集群配置,用于在 marathon 上运行的 zookeeper 恢复模式。通过控制台向 flink 集群提交应用程序的最佳实践是什么? taskmanager log , jobmanager log和 client out
最佳答案
您基本上必须使用与启动集群相同的 ZooKeeper 设置来配置 flink-conf.yaml
。鉴于您的 ZooKeeper 集群可以在 zookeeer.foobar.com:2181
下访问并且您已将 Flink 集群 ID 设置为 flinkCluster
,那么您必须插入以下配置设置进入 flink-conf.yaml
:
high-availability: zookeeper
high-availability.cluster-id: flinkCluster
high-availability.zookeeper.quorum: zookeeper.foobar.com:2181
更新
Flink 版本 1.2.x 包含一个错误,需要通过 jobmanager.rpc.address
和 jobmanager.rpc.port 设置
在 JobManager 的
地址和端口flink-conf.yaml
中。否则 ClusterClient
会因异常而失败,或者无法检索到可以与远程 JobManager
通信的正确 NIC。 FLINK-6629 描述了问题.
关于mesos - 通过控制台提交作业到flink-standalone zookeeper-recovery-mode集群的方式是什么?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/43923600/