[ https://issues.apache.org/jira/browse/FLINK-6362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
mingleizhang reassigned FLINK-6362: ----------------------------------- Assignee: mingleizhang > Unprotected access to registeredStates in > SharedStateRegistry#getReferenceCount > ------------------------------------------------------------------------------- > > Key: FLINK-6362 > URL: https://issues.apache.org/jira/browse/FLINK-6362 > Project: Flink > Issue Type: Bug > Components: State Backends, Checkpointing > Reporter: Ted Yu > Assignee: mingleizhang > > Here is related code: > {code} > public int getReferenceCount(SharedStateHandle state) { > if (state == null) { > return 0; > } > SharedStateRegistry.SharedStateEntry entry = > registeredStates.get(state.getRegistrationKey()); > {code} > Access should be protected by holding lock on registeredStates -- This message was sent by Atlassian JIRA (v6.4.14#64029)