Re: question on ValueState

2021-02-10 Thread Roman Khachatryan
t; https://github.com/apache/flink/blob/master/flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java >>>> [2] >>>> https://github.com/apache/flink/blob/master/flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/StateTable.ja

Re: question on ValueState

2021-02-08 Thread yidan zhao
eTable.java >> >> Best >> Yun Tang >> >> -- >> *From:* Colletta, Edward >> *Sent:* Sunday, February 7, 2021 19:53 >> *To:* user@flink.apache.org >> *Subject:* question on ValueState >> >> >> Using FsStateB

Re: question on ValueState

2021-02-08 Thread yidan zhao
blob/master/flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java >>> [2] >>> https://github.com/apache/flink/blob/master/flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/StateTable.java >>> >>> Best >>> Yun Tang >>> >>

Re: question on ValueState

2021-02-08 Thread Khachatryan Roman
gt; [2] > https://github.com/apache/flink/blob/master/flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/StateTable.java > > Best > Yun Tang > > -- > *From:* Colletta, Edward > *Sent:* Sunday, February 7, 2021 19:53 > *To:* user@flink

Re: question on ValueState

2021-02-07 Thread Yun Tang
/StateTable.java Best Yun Tang From: Colletta, Edward Sent: Sunday, February 7, 2021 19:53 To: user@flink.apache.org Subject: question on ValueState Using FsStateBackend. I was under the impression that ValueState.value will serialize an object which is stored

question on ValueState

2021-02-07 Thread Colletta, Edward
Using FsStateBackend. I was under the impression that ValueState.value will serialize an object which is stored in the local state backend, copy the serialized object and deserializes it. Likewise update() would do the same steps copying the object back to local state backend.And as a cons