开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

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

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

展开
收起
cuicuicuic 2023-09-05 16:53:49 28 0
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 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    ACK 云原生弹性方案—云原生时代的加速器 立即下载
    ACK集群类型选择最佳实践 立即下载
    企业运维之云原生和Kubernetes 实战 立即下载

    相关镜像