Hi:
我们现在启用state.backend.rocksdb.ttl.compaction.filter.enabled进行rocksdb的有效期设置,但效果并不是那么理想。
同时我也有以下问题想不明白:
1、如果rocksdb在compact的时候有些state并没有被compact到,是否就意味着就算这些state已经过期也不会被删除?
2、目前flink的ttl策略只有OnCreateAndWrite和OnReadAndWrite两种策略,是否有那种不需要刷新,到了TTL时间就自动清除。
否则就会出现state一直在刷新导致永远无法删除,最终导致磁盘打满目前我能想到的方案是,另外写一个定时任务根据配置去清除过期state。 请问大家还有其他更好的方案吗?
