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

Flink CDC本地调试,是不是启动的时候不会用chekpoint恢复,这种加上参数才行呢?

Flink CDC本地调试,是不是启动的时候不会用chekpoint恢复,需要像9311a82ccc33b7568ad6d5a164e6ed9b.png
这种加上参数才行呢

展开
收起
真的很搞笑 2023-11-06 20:05:46 103 0
1 条回答
写回答
取消 提交回答
  • 在Flink CDC的本地调试中,确实可以在启动的时候通过添加特定的参数来进行checkpoint恢复。你可以使用 -s 参数指定检查点目录,让新的作业读取该检查点元文件的信息和状态信息,从而达到从特定时间节点开始执行的效果。此外,还可以通过 flink.checkpoint.interval 参数来定义两次检查点之间的时间间隔,即多久执行一次检查点。这两个参数的使用上有一些细节需要注意,例如 flink.checkpoint.timeout 应该大于等于 flink.checkpoint.interval。同时,对于Savepoint(手动操作)的使用也需要注意一些要点,比如手动savepoint的步骤以及删除savepoint的方法。

    2023-11-07 11:10:42
    赞同 1 展开评论 打赏

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

相关产品

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

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