考虑下面的场景:

KeyBy userId, 把该 userId 所用的相关记录存起来放在 ListState 中
private transient ListState<String> list;

@Override
public void processElement(Tuple2<String, String> value, Context ctx, 
Collector<String> out)
    throws Exception {
    list.add(value.f1);
}
TTL 设为 7 天。
如果这个 userId 超过 7 天没有任何消息,那这个 userId 相应的 ListState 会被删除。
但如果这 userId 一直持续不断的有消息过来,那 7 天之前 被 add 到 list 的记录会不会被删除呢?

谢谢,
王磊


wangl...@geekplus.com

回复