Hi Boris Please refer to FLINK-12884[1] for current progress of native HA support of k8s which targets for release-1.12.
[1] https://issues.apache.org/jira/browse/FLINK-12884 Best Yun Tang ________________________________ From: Boris Lublinsky <boris.lublin...@lightbend.com> Sent: Tuesday, October 27, 2020 2:56 To: user <user@flink.apache.org> Subject: Flink checkpointing state This is from Flink 1.8: "Job Manager keeps some state related to checkpointing in it’s memory. This state would be lost on Job Manager crashes, which is why this state is persisted in ZooKeeper. This means that even though there is no real need for the leader election and -discovery part of Flink’s HA mode (as is this handled natively by Kubernetes), it still needs to be enabled just for storing the checkpoint state.” Was it ever fixed in Flink 1.10 or 1.11? If running Flink on K8, without HA, there is no Zookeeper. And if the above is still the case, then checkpointing will never pick up the right one
