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

请问那个checkpoint,是不是代码设置了然后flink平台也设置了,如果任务中途死了,还存在?

请问那个checkpoint,是不是代码设置了然后flink平台也设置了,然后如果任务中途死了,checkpoint还会存在对吧,任务回复时候会回到最近一个savepoint点对吧?这个savepoint是有cdc程序自己触发对吧,只要代码设置了savepoint参数。savepoint都存起来了,破灭也不会影响上次的记录点。

展开
收起
小易01 2023-07-19 17:58:45 37 0
1 条回答
写回答
取消 提交回答
  • 北京阿里云ACE会长

    在 Flink 中,Checkpoint 是一种容错机制,可以在 Flink 任务执行过程中周期性地将状态数据进行快照,并保存到外部存储中。当 Flink 任务发生故障时,可以使用 Checkpoint 来恢复任务的状态,从而实现任务的容错。
    Checkpoint 的使用需要两个方面的设置:一方面是代码设置,另一方面是 Flink 平台设置。
    代码设置是指在 Flink 应用程序中,通过编写代码来设置 Checkpoint 的相关参数,例如,设置 Checkpoint 的触发间隔、启用异步快照、设置 StateBackend 等。具体的设置方法可以参考 Flink 官方文档和 API 文档。
    Flink 平台设置是指在 Flink 集群中,通过配置 Flink 的参数来设置 Checkpoint 的相关参数,例如,设置 Checkpoint 的超时时间、启用外部化存储、设置 Checkpoint 根目录等。具体的设置方法可以参考 Flink 官方文档和配置文件。
    当 Flink 任务中途发生故障时,Checkpoint 中保存的状态数据可以用于恢复任务的状态。如果启用了外部化存储,Checkpoint 中保存的状态数据会保存在外部存储中,即使 Flink 任务中途死了,Checkpoint 中保存的状态数据仍然存在,可以用于后续的任务恢复。
    需要注意的是,Checkpoint 只能恢复到最近一次成功的 Checkpoint,因此,为了保证任务状态

    2023-07-29 19:54:30
    赞同 展开评论 打赏

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

相关产品

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

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