大佬,Flink CDC 中savepoint的有效时间是多少呀,我怎么感觉几分钟后就获取不到了(通过rest api获取sp的地址)There is no savepoint operation with triggerId=1053683933841a36b9e1a033705f475f for job cc21ed539b69ff44481cc9c83010f7b
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 将被保存在指定的路径下,而不是默认的路径下。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。