Re: Managed Keyed state update

Posted by Alexey Trenikhun on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Managed-Keyed-state-update-tp22284p22290.html

Clear. Thank you

 

---

From: Renjie Liu <[hidden email]>
Sent: Monday, August 13, 2018 4:33 PM
To: Alexey Trenikhun
Cc: [hidden email]
Subject: Re: Managed Keyed state update

 

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 <[hidden email]> 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?

--