嗯嗯,非常感谢你的回答,Congxian Qiu 。
Congxian Qiu 于2020年3月28日周六 上午11:39写道:
> Hi
>
> 这个地方我理解是,每次处理一定数量的 StateEntry 之后,会获取当前的 timestamp 然后在 RocksDB 的 compaction
> 时对所有的 StateEntry 进行 filter。
> > Calling of TTL filter during compaction slows it down.
>
> Best,
> Congxian
>
>
> LakeShen 于2020年3月26日周四
Hi
这个地方我理解是,每次处理一定数量的 StateEntry 之后,会获取当前的 timestamp 然后在 RocksDB 的 compaction
时对所有的 StateEntry 进行 filter。
> Calling of TTL filter during compaction slows it down.
Best,
Congxian
LakeShen 于2020年3月26日周四 下午8:55写道:
> Hi 社区的小伙伴,
>
> 我现在有个关于 Flink 1.10 RocksDBStateBackend 状态清理机制的问题,在 1.10中,RocksDB
Hi 社区的小伙伴,
我现在有个关于 Flink 1.10 RocksDBStateBackend 状态清理机制的问题,在 1.10中,RocksDB 默认使用 in
background 方式进行状态清理,使用 compaction filter 方式。正如官方文档所说:
> RocksDB compaction filter will query current timestamp, used to check
> expiration, from Flink every time after processing certain number of state
>