开发者社区> 问答> 正文

Flink中的checkpoint具体是指什么啊?

Flink中的checkpoint具体是指什么啊?

展开
收起
游客vwuxaq6iqaowc 2021-12-08 15:25:32 301 0
1 条回答
写回答
取消 提交回答
  • checkpoint是把job的所有状态都周期性持久化到存储里,当出现故障时,从最新的一次检查点恢复

    默认状态下,检查点不被保留,仅用于从故障中恢复作业

    checkpointmode:exactly_once/at_least_once

    提供exactly_once语意保证,只保证flink内部,对于sink和source需要依赖外部组件

    一般情况下选择exactly_once,除非场景要求极低的延迟

    checkpoint的保留策略

    DELETE_ON_CANCELLATION:仅当作业失败时,作业的 Checkpoint 才会被保留用于任务恢复。当作业取消时,Checkpoint 状态信息会被删除,因此取消任务后,不能从 Checkpoint 位置进行恢复任务。

    RETAIN_ON_CANCELLATION:当作业手动取消时,将会保留作业的 Checkpoint 状态信息。注意,这种情况下,需要手动清除该作业保留的 Checkpoint 状态信息,否则这些状态信息将永远保留在外部的持久化存储中。

    2021-12-08 15:25:53
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

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