[FLINK-31626] HsSubpartitionFileReaderImpl should recycle skipped read buffers.

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.17.1
• Fix Version/s: 1.18.0, 1.17.1
• Component/s: Runtime / Network
• Labels: pull-request-available
• Assignee: Weijie Guo
• Reporter: Weijie Guo
• Created: 27/Mar/23 08:45
• Updated: 31/Mar/23 09:42
• Resolved: 31/Mar/23 09:42

Description

In FLINK-30189, HsSubpartitionFileReaderImpl will skip the buffer has been consumed from memory to avoid double-consumption. But these buffers were not returned to the BatchShuffleReadBufferPool, resulting in read buffer leaks. In addition, all loaded buffers should also be recycled after data view released.

Issue Links

• links to: GitHub Pull Request #22280