[GitHub] flink issue #5934: [FLINK-9269][state] fix concurrency problem when performi...

[sihuazhou]

Github user sihuazhou commented on the issue:

    https://github.com/apache/flink/pull/5934
  
    Hi @StefanRRichter sorry for the unclearly description here. What this PR 
trying to fix is the mainly relate to the below code which run async:
    ```java
    for (Map.Entry<String, StateTable<K, ?, ?>> kvState : 
stateTables.entrySet()) {
       // do something                                                          
        
    } // this will just close the outer compression stream
    ```
    the `stateTables` may cause concurrency problem.


---