开发者社区> 问答> 正文

如何在 Flink 配置中启用 Generic Log-Based Incremental?

如何在 Flink 配置中启用 Generic Log-Based Incremental Checkpointing?

展开
收起
圆葱猪肉包 2024-08-21 15:48:11 47 0
1 条回答
写回答
取消 提交回答
  • 可以在 flink-conf.yaml 文件中进行如下设置:

    state.backend.changelog.enabled: true 
    state.backend.changelog.storage: filesystem 
    dstl.dfs.base-path: <location similar to state.checkpoints.dir>
    

    这里需要指定 Changelog 是否启用(state.backend.changelog.enabled),存储类型(state.backend.changelog.storage),以及 DFS 的基础路径(dstl.dfs.base-path)。

    2024-08-21 17:30:36
    赞同 6 展开评论 打赏
问答排行榜
最热
最新

相关电子书

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