Sihua Zhou created FLINK-8699: --------------------------------- Summary: Fix concurrency problem in rocksdb full checkpoint Key: FLINK-8699 URL: https://issues.apache.org/jira/browse/FLINK-8699 Project: Flink Issue Type: Bug Components: State Backends, Checkpointing Affects Versions: 1.5.0 Reporter: Sihua Zhou Assignee: Sihua Zhou Fix For: 1.5.0
In full checkpoint, `kvStateInformation` is not a copied object and it can be changed when writeKVStateMetaData() is invoking ... This can lead to problematic, which is serious. {code} private void writeKVStateMetaData() throws IOException { // ... for (Map.Entry<String, Tuple2<ColumnFamilyHandle, RegisteredKeyedBackendStateMetaInfo<?, ?>>> column : stateBackend.kvStateInformation.entrySet()) { } //... } {code} -- This message was sent by Atlassian JIRA (v7.6.3#76005)