FLIP-547: Support checkpoint during recovery#27639

Open

1996fanrui wants to merge 15 commits intoapache:masterfrom

1996fanrui:38544/checkpointing-during-recovery

Commits on Mar 5, 2026

Commits on Mar 18, 2026

[FLINK-38541][checkpoint] Introducing config option: execution.checkpointing.unaligned.during-recovery.enabled
1996fanrui
committed

Commits on Mar 20, 2026

[FLINK-38930][checkpoint] Filtering record before processing without spilling strategy
1996fanrui
committed
[hotfix][network] Fix LocalInputChannel.getBuffersInUseCount to include toBeConsumedBuffers
1996fanrui
committed
[FLINK-39018][checkpoint] Support LocalInputChannel checkpoint snapshot for recovered buffers
1996fanrui
committed
[FLINK-39018][network] Fix LocalInputChannel priority event and buffer availability for recovered buffers
1996fanrui
committed
[FLINK-38543][network] Buffer migration from RecoveredInputChannel to physical channels
1996fanrui
committed
[FLINK-38543][checkpoint] Fix Mailbox loop interrupted before recovery finished
1996fanrui
committed
[FLINK-38543][checkpoint] Introduce bufferFilteringCompleteFuture for earlier RUNNING state transition
1996fanrui
committed
[FLINK-38543][checkpoint] Change overall UC restore process for checkpoint during recovery
1996fanrui
committed
[FLINK-38544][checkpoint] Use heap buffer as simplified spilling logic during recovery
1996fanrui
committed
[FLINK-39018][checkpoint] Notify PriorityEvent to downstream task even if it is blocked to ensure the checkpoint barrier can be handled by downstream task
1996fanrui
committed
[FLINK-38541][checkpoint] Expose checkpointing during recovery config option in documentation
1996fanrui
committed
[FLINK-38541][checkpoint] Randomize UNALIGNED_DURING_RECOVERY_ENABLED for testing
1996fanrui
committed