咱们有做flink on k8s application模式下获取保存点的吗?

咱们有做flink on k8s application模式下获取保存点的吗?

展开
收起
真的很搞笑 2023-09-05 16:53:49 120 分享 版权
1 条回答
写回答
取消 提交回答
  • 是的,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社区也提供了丰富的资源和文档,可以帮助您更好地理解和使用保存点功能。

    2023-10-18 15:02:51
    赞同 展开评论

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

还有其他疑问?
咨询AI助理