[
https://issues.apache.org/jira/browse/FLINK-39523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-39523:
----------------------------
Summary: Support checkpoint coordination during recovery via a
recovery-checkpoint trigger (memory-based) (was: Support streaming
addInputData for spilled recovery data)
> Support checkpoint coordination during recovery via a recovery-checkpoint
> trigger (memory-based)
> ------------------------------------------------------------------------------------------------
>
> Key: FLINK-39523
> URL: https://issues.apache.org/jira/browse/FLINK-39523
> Project: Flink
> Issue Type: Sub-task
> Components: Runtime / Checkpointing
> Reporter: Rui Fan
> Assignee: Rui Fan
> Priority: Major
>
> Adds an `addInputData(checkpointId, channelInfo, startSeqNum, InputStream,
> dataLength)` overload to `ChannelStateWriter`, along with the matching
> `ChannelStateWriteRequest` factory and a
> `ChannelStateCheckpointWriter.writeInputStreaming()` path that copies bytes
> via `InputStream.transferTo()`. This lets spilled recovery data be
> checkpointed without allocating Network or heap buffers. The on-disk write
> format (`[4B length][data]`) and the recovery read path are unchanged.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
