[WIP][FLINK-39519] Allocate pre-filter source buffers from heap in filtering mode#28073

Draft

1996fanrui wants to merge 17 commits intoapache:masterfrom

1996fanrui:39519/spilling

Commits on Apr 29, 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
[FLINK-39519][checkpoint] Simplify comments in the unaligned-recovery filter pipeline
1996fanrui
committed
[FLINK-39519][checkpoint] Apply pending spotless formatting
1996fanrui
committed
[FLINK-39519][checkpoint] Rename Reader sealed/seal to frozen/freeze
1996fanrui
committed
[FLINK-39519][checkpoint] Release recovered store on abort path
1996fanrui
committed
[FLINK-39519][checkpoint] Signal markDrainDone when no dispatcher is created
1996fanrui
committed

Commits on Apr 30, 2026