开发者社区> 问答> 正文

如何在Kubernetes Flink集群中实现JobManager高可用性?

社区小助手 2018-12-11 16:29:05 1156

我注意到Flink官方文档为Standalone和Yarn Flink集群提供了一个jobmanager高可用性解决方案。但是使用Kubernetes Flink Cluster应该如何实现高可用性?

从文档的Kubernetes Setup部分看,我们在使用Kubernetes集群进行部署时似乎只部署了一个Jobmanager。那么如何使用Kubernetes Flink Cluster实现HA?

资源调度 Kubernetes 流计算 容器
分享到
取消 提交回答
全部回答(1)
  • 社区小助手
    2019-07-17 23:19:52

    作业管理器的高可用性是用来处理作业管理器崩溃的情况。所以只需要一个job manager,但你想要处理它失败的情况。在Kubernetes上如果它发生故障,那么Kubernetes应该检测到这一点并自动重新启动它。所以你不需要运行它的更多副本。

    (它似乎没有对Kubernetes说明这一点,但是重新启动失败的pod是Kubernetes的标准行为)。

    任务管理器默认情况下与官方K8S资源上Kubernetes多个副本(见“副本”条目运行配置中的资源),但作业管理是没有的。(并且在helm图表中也是如此。)所以我认为job manager不需要它 - 我建议与一个job manager一起运行,除非你遇到特定的问题。

    0 0
+ 订阅

云原生时代,是开发者最好的时代

推荐文章
相似问题
推荐课程