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

标签 mesos apache-flink marathon

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

关于mesos - 通过控制台提交作业到flink-standalone zookeeper-recovery-mode集群的方式是什么?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/43923600/

相关文章:

java - 如何在 Flink 服务器上连续运行 apache flink streaming job

apache-spark - 来自 Kafka 的 Spark Streaming 有错误 numRecords 不能为负

amazon-web-services - .dockercfg文件应如何托管在AWS上的Mesosphere设置中,以便只有Mesosphere可以使用它?

c++ - 如何将现有的分布式服务应用移植到DCOS?

java - 由于 "Timeout expired while fetching topic metadata"导致消费 Kafka 失败

docker - 马拉松任务永无止境

docker - 通过Aurora在Mesos中使用大型Docker镜像启 Action 业可能很慢

scala - Apache Flink 上的 zipWithIndex

ubuntu-14.04 - Mesosphere - 高可用性集群未能选举领导者,但日志显示没有错误并且似乎无法强制选举领导者

mesos - Fig/Docker-Compose-like JSON 输入 Mesosphere/Marathon 以设置多层应用程序