开发者社区> 问答> 正文

Flink键控状态清理增量rocksdb检查点

Flink键控状态清理增量rocksdb检查点
我有一个flink工作,可以在rocksdb后端保持大键控状态。我们正在使用增量检查点策略。随着时间的推移,状态的规模成为一个问题。我们检查了状态ttl解决方案,但它不支持增量的rocksdb状态。

如果我真的需要增量检查点,那么这个问题的最佳方法是什么?

展开
收起
flink小助手 2018-12-14 14:03:31 2972 0
1 条回答
写回答
取消 提交回答
  • flink小助手会定期更新直播回顾等资料和文章干货,还整合了大家在钉群提出的有关flink的问题及回答。

    经常使用的一种方法是在某种ProcessFunction中操纵状态,并在在不需要时使用计时器来清除状态 - 例如,如果它已经被访问了几个小时。ProcessFunctions可以同时具有事件时间和处理时间计时器,因此您可以选择哪个更适合您的用例。

    2019-07-17 23:20:55
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

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