flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Renjie Liu <liurenjie2...@gmail.com>
Subject Re: Managed Keyed state update
Date Mon, 13 Aug 2018 23:33:35 GMT
Hi, Alexey:
It depends on the state backend you use. If you use heap memory backend,
then you don't need to do put again.
However, if you use rocksdb state backend, then you need to do the put
again so that it will be saved by the checkpoint.

On Tue, Aug 14, 2018 at 4:58 AM Alexey Trenikhun <yender@msn.com> wrote:

> Let’s say I have Managed Keyed state -
> MapState<String,Tuple2<String,String>> x, I initialize for state for “k0”
> x.put(“k0”, new Tuple2<>(“a”, “b”));
> Later  I retried state Tuple2<String,String> v = x.get(“k0”); and change
> value: v.f0=“U”;, does it make state ‘dirty’? In other words, do I need to
> call x.put(“k0”, v) again or change will be saved by checkpoint anyway
> because value was changed?
> Alexey
Liu, Renjie
Software Engineer, MVAD

View raw message