Re: question on ValueState

2021-02-10 Thread Roman Khachatryan
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 >>>> >>>>

Re: question on ValueState

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

Re: question on ValueState

2021-02-08 Thread yidan zhao
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
t; 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.apache.or

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