通过控制台提交作业到flink-standalone zookeeper-recovery-mode集群的方式是什么?

what is the way to submit jobs via console to flink-standalone zookeeper-recovery-mode cluster?

我有一个 flink 集群配置,用于在 marathon 上运行的 zookeeper 恢复模式。通过控制台向flink集群提交应用的最佳实践是什么?taskmanager log ,jobmanager log and 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 包含一个错误,需要在 flink-conf.yaml 中通过 jobmanager.rpc.addressjobmanager.rpc.port 设置 JobManager's 地址和端口.否则 ClusterClient 会因异常而失败,或者无法检索到可以与远程 JobManager 通信的正确 NIC。 FLINK-6629.

描述了问题