开发者社区> 问答> 正文
1
0
分享

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

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

展开
收起
圆葱猪肉包 2024-08-21 15:48:11 55 0 发布于黑龙江
举报
飞天免费试用计划
领取免费云资源,开启云上实践第一步
实时计算 Flink 版
5000CU*H 3个月
额度3个月内有效
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 评论 打赏

    评论

    全部评论 (0)

    登录后可评论
问答排行榜
最热
最新

相关电子书

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

你好,我是AI助理

可以解答问题、推荐解决方案等