[FLINK-22325] Channel state iterator is accessed concurrently without proper synchronization

• Type: Bug
• Status: Closed
• Priority: Critical
• Resolution: Invalid
• Affects Version/s: 1.13.0
• Fix Version/s: 1.13.0
• Component/s: Runtime / Checkpointing
• Labels: pull-request-available
• Assignee: Roman Khachatryan
• Reporter: Roman Khachatryan
• Created: 16/Apr/21 15:29
• Updated: 28/May/21 09:09
• Resolved: 17/Apr/21 09:07

Description

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.

Issue Links

• links to: GitHub Pull Request #15646