Flink作业群集Kubernetes从保存点恢复

Question

我们目前正在kubernetes上运行flink，作为使用这个helm模板的作业集群：https://github.com/docker-flink/examples/tree/master/helm/flink（带有一些添加的配置）。

如果我想关闭集群，重新部署新映像（由于应用程序代码更新）并重新启动，我将如何从保存点进行恢复？

jobManager命令严格设置在standalone-job.sh命令上，如果我在部署k8s资源的参数中添加一个保存点，那么如果flink重新启动（由于一些系统误差），它将始终从该保存点重新启动，这不是我们想要的。

有没有办法从最新的保存点恢复，如果该保存点不存在，它将从kubernetes作业集群helm配置重新开始？

Answer 1

我不认为我理解你的全部设置，但我从你的问题中读到你有你的Flink集群

您可以定期创建保存点，并使用最新的保存点id更新配置。

Flink恢复脚本不应指向特定的保存点，而应指向始终包含最新保存点id的配置值。

根据Flink作业的变化，从保存点恢复并非总是可能的，因此您也需要考虑这种情况。