flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Paul Lam <paullin3...@gmail.com>
Subject How to clear keyed states periodically?
Date Wed, 12 Sep 2018 10:06:10 GMT

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!

Paul Lam
View raw message