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)
