Flink CDC本地调试,是不是启动的时候不会用chekpoint恢复,需要像
这种加上参数才行呢
在Flink CDC的本地调试中,确实可以在启动的时候通过添加特定的参数来进行checkpoint恢复。你可以使用 -s
参数指定检查点目录,让新的作业读取该检查点元文件的信息和状态信息,从而达到从特定时间节点开始执行的效果。此外,还可以通过 flink.checkpoint.interval
参数来定义两次检查点之间的时间间隔,即多久执行一次检查点。这两个参数的使用上有一些细节需要注意,例如 flink.checkpoint.timeout
应该大于等于 flink.checkpoint.interval
。同时,对于Savepoint(手动操作)的使用也需要注意一些要点,比如手动savepoint的步骤以及删除savepoint的方法。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。