Flink Statefun HA Kubernetes群集

Question

我正在尝试在kubernetes上部署高可用性flink集群。在下面的示例中，工作节点被复制，但是我们只有一个主容器。

https://github.com/apache/flink-statefun

据我了解，有两种方法可以使作业管理器成为HA。

1. https://ci.apache.org/projects/flink/flink-docs-stable/ops/jobmanager_high_availability.html
2. https://medium.com/hepsiburadatech/high-available-flink-cluster-on-kubernetes-setup-73b2baf9200e

在第一个示例中，我们部署了另一个作业管理器以在发生故障时在它们之间切换在第二个示例中，kubernetes在失败的情况下重新部署作业管理器窗格

所以我有几个问题

• 对于两个示例，当活动作业管理器发生故障时正在运行的作业会发生什么？
• 第一种情况可以应用于kubernetes吗？

• 对于第二种情况，如果作业管理器发生故障，则在容器恢复之前，flink UI将不可用，但是在第二种情况下，可以使用吗？

• 两种情况的优点/缺点是什么？

我正在尝试在kubernetes上部署高可用性flink集群。在下面的示例中，工作节点被复制，但是我们只有一个主容器。 https://github.com/apache/flink-statefun到目前为止...

Answer 1

[有一种方法可以使作业管理器HA，您的两个链接都使用了JM HA，并使用zookeeper集群来创建JM的活动/备用架构。

1. 当JobManager发生故障时，将出现“故障转移”，如apache flink文档（第一个链接）中所述，备用JM变为活动状态。