[jira] [Created] (FLINK-22325) Channel state iterator is accessed concurrently without proper synchronization

[Shang Yuanchun (Jira)]

Roman Khachatryan created FLINK-22325:
-----------------------------------------

             Summary: Channel state iterator is accessed concurrently without proper synchronization
                 Key: FLINK-22325
                 URL: https://issues.apache.org/jira/browse/FLINK-22325
             Project: Flink
          Issue Type: Bug
          Components: Runtime / Checkpointing
            Reporter: Roman Khachatryan
            Assignee: Roman Khachatryan
             Fix For: 1.13.0


ChannelStateWriter adds input/output data that is written by a dedicated thread.

The data is passed as CloseableIterator.

In some cases, iterator.close can be called from the task thread which can lead to double release of buffers.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)