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

Flink CDC 中savepoint的有效时间是多少呀?

大佬,Flink CDC 中savepoint的有效时间是多少呀,我怎么感觉几分钟后就获取不到了(通过rest api获取sp的地址)There is no savepoint operation with triggerId=1053683933841a36b9e1a033705f475f for job cc21ed539b69ff44481cc9c83010f7b

展开
收起
真的很搞笑 2023-08-28 15:16:29 67 0
1 条回答
写回答
取消 提交回答
  • Flink CDC 中的 savepoint 的有效时间由 checkpoint.restore.savepoint.min-validity-time 配置项指定。默认情况下,savepoint 的有效时间为 10 分钟。如果超过 10 分钟没有恢复该 savepoint,那么该 savepoint 将被自动删除。

    你可以通过修改 checkpoint.restore.savepoint.min-validity-time 配置项来调整 savepoint 的有效时间。但是,请注意,savepoint 的有效时间过长可能会导致 checkpoint 的开销增加。

    另外,Flink CDC 还支持使用 checkpoint.restore.savepoint-path 配置项指定 savepoint 的路径。如果指定了 checkpoint.restore.savepoint-path,那么 savepoint 将被保存在指定的路径下,而不是默认的路径下。

    2023-09-13 11:53:08
    赞同 展开评论 打赏

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

相关产品

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

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载