考虑下面的场景: 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