[GitHub] flink pull request #5934: [FLINK-9269][state] fix concurrency problem when p...

[sihuazhou]

Github user sihuazhou commented on a diff in the pull request:

    https://github.com/apache/flink/pull/5934#discussion_r185486196
  
    --- Diff: 
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
 ---
    @@ -1987,6 +1987,8 @@ private void writeKVStateMetaData() throws 
IOException {
     
                        KeyedBackendSerializationProxy<K> serializationProxy =
                                new KeyedBackendSerializationProxy<>(
    +                                   // we use the statBackend's 
keySerializer directly here, because it just be written here.
    +                                   // NOTE: There's a loophole when the 
serializer is stateful, but that rarely occur in reality use case.
    --- End diff --
    
    👍 


---