flink官方文档为独立集群和flink集群提供了jobmanager高可用性解决方案。但是使用mesos-flink集群应该如何实现高可用性呢?
我了解到,flink依靠marathon来提出一个失败的jobmanager,但它带来了一个问题:每次jobmanager重新启动时,都会重新部署作业。这对于任务关键型工作是不可接受的。这个问题有解决办法吗?或者是否有任何计划支持完整的ha与Flink在Mesos模式?
flink官方文档为独立集群和flink集群提供了jobmanager高可用性解决方案。但是使用mesos-flink集群应该如何实现高可用性呢?
我了解到,flink依靠marathon来提出一个失败的jobmanager,但它带来了一个问题:每次jobmanager重新启动时,都会重新部署作业。这对于任务关键型工作是不可接受的。这个问题有解决办法吗?或者是否有任何计划支持完整的ha与Flink在Mesos模式?
1条答案
按热度按时间uqxowvwt1#
我在flink中使用了这个配置,它确实适用于两个mesos主机和一个从机:
另外,我在marathon中使用了这个json文件:
我希望它有用。