Rui Fan created FLINK-39519:
-------------------------------
Summary: Allocate pre-filter source buffers from heap in filtering
mode
Key: FLINK-39519
URL: https://issues.apache.org/jira/browse/FLINK-39519
Project: Flink
Issue Type: Sub-task
Components: Runtime / Checkpointing
Reporter: Rui Fan
Assignee: Rui Fan
In filtering mode, the pre-filter source buffer used by
`RecoveredChannelStateHandler.getBuffer()` is now allocated from heap (bounded
to 5 per gate) instead of the Network Buffer Pool, preventing deadlock between
source and filtered buffers. Also adds a non-blocking
`RecoveredInputChannel.requestBuffer()` used by OutputWriter, and removes the
unbounded heap fallback from `requestBufferBlocking()` in filtering mode.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
