前言
总结 Flink HA
版本
- Flink 1.15.3、1.15.4
官方文档
https://nightlies.apache.org/flink/flink-docs-release-1.19/zh/docs/deployment/ha/overview/
由官方文档可知:
- HA 是对于 JobManager 的故障恢复,默认情况下,每个 Flink 集群只有一个 JobManager 实例,如果 JobManager 崩溃,则不能提交任何新程序,运行中的程序也会失败。如果配置了HA,则可以从 JobManager 失败中恢复。而对于 TaskManager ,HA 则不生效,可以通过配置 Flink 重启策略和故障恢复策略
- 支持两种高可用:ZooKeeper、Kubernetes,本文只总结 ZooKeeper 高可用 more >>