[FLINK-38544] Allocate pre-filter source buffers from heap in filtering mode#28107

Open

1996fanrui wants to merge 7 commits intoapache:masterfrom

1996fanrui:39519/spilling-dev

Commits on May 4, 2026

[FLINK-39524][checkpoint] Add non-blocking requestBuffer() and remove heap fallback from requestBufferBlocking()
1996fanrui
committed
[FLINK-39520][checkpoint] Add spill file I/O and RecoveredBufferStore
1996fanrui
committed
[FLINK-39521][checkpoint] Add OutputWriter to dispatch filtered records to buffer, disk, or drain
1996fanrui
committed
[FLINK-39522][network] Consume recovered buffers from RecoveredBufferStore in input channels
1996fanrui
committed
[FLINK-39523][checkpoint] Support streaming InputStream-based addInputData for spilled recovery data
1996fanrui
committed
[FLINK-39524][checkpoint] Wire OutputWriter into the filterAndRewrite recovery flow
1996fanrui
committed
Fix for recovery stall when CHECKPOINTING_DURING_RECOVERY_ENABLED=true hits a NO_RESCALE input descriptor
1996fanrui
committed