如何在Mesos集群中运行flink jar文件
如何在Mesos集群中运行flink jar文件
提问于 2019-03-04 07:42:39
我有两个节点，码头已经安装在它们上。此外，我还在码头上安装了Apache。首先，在没有显示任何结果的docker中运行此命令：
/home/flink-1.7.0/bin/mesos-appmaster.sh -Djobmanager.heap.mb=1024 -Djobmanager.rpc.port=6123 -Drest.port=8081 -Dmesos.resourcemanager.tasks.mem=1024 -Dtaskmanager.heap.mb=1024 -Dtaskmanager.numberOfTaskSlots=2 -Dparallelism.default=2 -Dmesos.resourcemanager.tasks.cpus=1之后，我运行以下命令来运行jar文件：
/home/flink-1.7.0/bin/flink run -m 172.28.10.133:5050 /home/Flink_Cassandra_test_jar/Flink_Cassandra_test.jar在那之后，我得到了一个错误：
org.apache.flink.client.deployment.ClusterRetrieveException:无法检索独立集群
顺便说一下，我也配置了动物园管理员。另外，我在Flink yaml文件中添加了这两行：
jobmanager.rpc.address: 150.20.11.133
high-availability: zookeeper
high-availability.zookeeper.quorum: 150.20.11.133:2181请告诉我如何在mesos集群上运行flink jar文件好吗？
任何帮助都将不胜感激。
回答 1
Stack Overflow用户
发布于 2019-09-05 17:46:42
在flink-conf.yaml文件中填充此参数。
mesos.master: IP-MASTER-MESOS:5050
mesos.initial-tasks: 10
mesos.resourcemanager.tasks.container.type: mesos
jobmanager.heap.mb: 1024
jobmanager.web.address: 130.239.48.136
jobmanager.web.port: 8081
mesos.resourcemanager.tasks.mem: 4096
taskmanager.heap.mb: 3500
mesos.resourcemanager.tasks.cpus: 2
mesos.resourcemanager.tasks.disk: 4096
mesos.resourcemanager.tasks.taskmanager-cmd: "/home/flink/flink-1.9.0/bin/mesos-taskmanager.sh"
mesos.resourcemanager.artifactserver.ssl.enabled: false
mesos.resourcemanager.framework.name: "FLINK_on_MESOS_intensive_cpu_usage"然后运行您的应用程序：
/home/flink/flink-1.9.0/bin/flink run -c org.sense.flink.App /home/flink/explore-flink/target/you-application-flink.jarMesos会将任务管理器、需要的插槽分配给Flink。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/54978643
复制相关文章
相似问题
腾讯云开发者
