flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vino yang <yanghua1...@gmail.com>
Subject Re: How to clear keyed states periodically?
Date Fri, 14 Sep 2018 02:39:30 GMT
Hi Paul,

Maybe you can try to understand the State TTL?[1]

Thanks, vino.

[1]:
https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/stream/state/state.html#state-time-to-live-ttl

Paul Lam <paullin3280@gmail.com> 于2018年9月12日周三 下午6:06写道:

> Hi,
>
> I’m using MapState to deduplicate some ids and the MapState needs to be
> truncated periodically. I tried to use ProcessingTimeCallback to call
> state.clear(), but in this way I can only clear the state for one key, and
> actually I need a key group level cleanup. So I’m wondering is there any
> best practice for my case? Thanks a lot!
>
> Best,
> Paul Lam

Mime
View raw message