咱们有做flink on k8s application模式下获取保存点的吗?
是的,Flink on Kubernetes支持获取和管理保存点(Savepoints)。保存点是Flink任务的快照,可以用于在任务出现故障或需要停止并恢复任务时进行恢复。
在Flink on Kubernetes中,您可以使用以下方法来获取和管理保存点:
手动触发保存点:您可以使用Flink的CLI命令或REST API手动触发保存点。例如,您可以使用如下命令:
```./bin/flink savepoint [targetDirectory]
```
其中,是要保存点的任务的ID,[targetDirectory]是保存点的目标目录。
自动保存点:您可以通过配置Flink任务的参数来自动触发保存点。通过设置state.checkpoints.interval参数,可以指定保存点的间隔时间。例如,设置为10s表示每10秒自动触发一个保存点。
管理保存点:Flink on Kubernetes提供了API和CLI命令来管理保存点。您可以使用kubectl命令或Flink的REST API来列出、删除或恢复保存点。
需要注意的是,保存点是与特定的Flink任务相关联的。这意味着每个任务都有自己的保存点。在获取保存点时,您需要指定相应任务的ID或名称。
如果您想了解更多关于Flink on Kubernetes中保存点的详细信息,建议您参考Flink官方文档中有关Flink on Kubernetes的章节。此外,Flink社区也提供了丰富的资源和文档,可以帮助您更好地理解和使用保存点功能。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。