[ 
https://issues.apache.org/jira/browse/FLINK-6467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16020613#comment-16020613
 ] 

Ted Yu commented on FLINK-6467:
-------------------------------

Alright.

> Potential lack of synchronization w.r.t. newSstFiles in 
> RocksDBKeyedStateBackend#releaseResources()
> ---------------------------------------------------------------------------------------------------
>
>                 Key: FLINK-6467
>                 URL: https://issues.apache.org/jira/browse/FLINK-6467
>             Project: Flink
>          Issue Type: Bug
>          Components: State Backends, Checkpointing
>            Reporter: Ted Yu
>            Priority: Minor
>
> {code}
>       if (canceled) {
>         List<StateObject> statesToDiscard = new ArrayList<>();
>         statesToDiscard.add(metaStateHandle);
>         statesToDiscard.addAll(miscFiles.values());
>         statesToDiscard.addAll(newSstFiles.values());
> {code}
> It seems access to newSstFiles should be protected by 
> stateBackend.asyncSnapshotLock



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

Reply via email to