有什么更好的方法能对rocksdb的有效期进行设置吗？
我们现在启用state.backend.rocksdb.ttl.compaction.filter.enabled进行rocksdb的有效期设置，但效果并不是那么理想。 同时我也有以下问题想不明白： 1、如果rocksdb在compact的时候有些state并没有被compact到，是否就意味着就算这些state已经过期也不会被删除？ 2、目前flink的ttl策略只有OnCreateAndWrite和OnReadAndWrite两种策略，是否有那种不需要刷新，到了TTL时间就自动清除。 否则就会出现state一直在刷新导致永远无法删除，最终导致磁盘打满
目前我能想到的方案是，另外写一个定时任务根据配置去清除过期state。 请问大家还有其他更好的方案吗？*来自志愿者整理的FLINK邮件归档
写回答
-
1 不参加 compaction 的不会被删除 2 TTL state 暂时无法做到一到时间就清除（我理解你这里担心不删除会有磁盘打满的风险），实际上现在会周期性的清理 state 的。另外如果你真的希望严格控制 state 的过期时间，或者你可以尝试下 ProcessFunction[1] 自己使用 Timer 相关的来控制 State 的生命周期
[1] https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/stream/operators/process_function.html*来自志愿者整理的FLINK邮件归档
2021-12-03 19:02:39赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
