[jira] [Updated] (FLINK-39521) Support push-based recovery in input channels

["Rui Fan (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-39521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Rui Fan updated FLINK-39521:
----------------------------
    Summary: Support push-based recovery in input channels  (was: Add OutputWriter for post-filter record dispatch)

> Support push-based recovery in input channels
> ---------------------------------------------
>
>                 Key: FLINK-39521
>                 URL: https://issues.apache.org/jira/browse/FLINK-39521
>             Project: Flink
>          Issue Type: Sub-task
>            Reporter: Rui Fan
>            Assignee: Rui Fan
>            Priority: Major
>
> Introduces `OutputWriter` / `OutputWriterImpl`, which routes post-filter bytes into one of three paths per `write()`: fill the active Network Buffer (P1), spill to disk when no buffer is available (P2), or eagerly drain disk back into a buffer when one frees up (P3). `flush()` seals the active buffer; `close()` performs a blocking drain to exhaust remaining disk data; `checkpointPendingEntries()` streams all queued disk entries into a checkpoint in one sequential pass.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)