Flink State的过期删除策略有哪些?

提问者:帅平 问题分类:面试刷题
Flink State的过期删除策略有哪些?
1 个回答
还有寂寞陪着我
还有寂寞陪着我
下面是 State 的过期删除策略:
1、lazy 删除策略:  访问 State 的时候根据时间戳判断是否过期,如果过期则主动删除 State 数据。 以 ValueState 为例,在 ValueState.value()  时会进行判断是否过期。这个删除策略是不需要用户进行配置的,只要你打开了 State TTL 功能,就会默认执行。
2、cleanup in full snapshot 删除策略: 此删除策略本地状态不会被清除,但在从前一个快照恢复时,它不会包含已删除的过期状态, 也就是说会在状态恢复(checkpoint、savepoint)时做过期删除。
发布于:3个月前 (02-06) IP属地:四川省
我来回答