[jira] [Closed] (FLINK-8699) Fix concurrency problem in rocksdb full checkpoint
[ https://issues.apache.org/jira/browse/FLINK-8699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sihua Zhou closed FLINK-8699. - Resolution: Fixed Release Note: (was: Richter has fixed this in his hotfix.) > 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 >Priority: Blocker > 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.EntryRegisteredKeyedBackendStateMetaInfo>> column : > stateBackend.kvStateInformation.entrySet()) { > } > //... > } > {code} -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Closed] (FLINK-8699) Fix concurrency problem in rocksdb full checkpoint
[ https://issues.apache.org/jira/browse/FLINK-8699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-8699. - Resolution: Fixed Merged inĀ 21cf59d5ff > 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 >Priority: Blocker > 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.EntryRegisteredKeyedBackendStateMetaInfo>> column : > stateBackend.kvStateInformation.entrySet()) { > } > //... > } > {code} -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Closed] (FLINK-8699) Fix concurrency problem in rocksdb full checkpoint
[ https://issues.apache.org/jira/browse/FLINK-8699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sihua Zhou closed FLINK-8699. - Resolution: Fixed Release Note: Richter has fixed this in his hotfix. > 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 >Priority: Blocker > 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.EntryRegisteredKeyedBackendStateMetaInfo>> column : > stateBackend.kvStateInformation.entrySet()) { > } > //... > } > {code} -- This message was sent by Atlassian JIRA (v7.6.3#76005)