Rui Fan created FLINK-39523:
-------------------------------
Summary: Support streaming addInputData for spilled recovery data
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
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)
