kubernetes - 如何在 Kubernetes Flink 集群中实现 JobManager 高可用？

Question

Flink 官方文档提供了 jobmanager high availability Standalone 和 Yarn Flink 集群的解决方案。但是使用 Kubernetes Flink 集群应该怎么做才能实现高可用性呢？

来自 Kubernetes Setup文档的一部分，似乎我们在部署到 Kubernetes 集群时只部署了一个 Jobmanager。那么Kubernetes Flink集群如何实现HA呢？

Answer 1

official doc says作业管理器的高可用性是为了处理作业管理器崩溃的情况。所以只需要一个作业管理器，但你想处理它出现故障的情况。在 Kubernetes 上，如果它出现故障，那么 Kubernetes 应该检测到这一点并自动重新启动它。所以你不需要运行它的更多副本。

(文档说这个 explicitly about using yarn for ha 。它似乎没有说明 Kubernetes 但重新启动失败的 Pod 是 standard behaviour for Kubernetes 。)

默认情况下，任务管理器配置为在官方 k8s 资源中的 Kubernetes 上使用多个副本运行(请参阅“副本”条目 in the resources)，但作业管理器不是。 (它是 same in the helm chart 。)所以我相信作业管理器不需要它 - 我建议使用单个作业管理器运行，除非您遇到特定问题。