You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Rui Fan (Jira)" <ji...@apache.org> on 2026/04/22 16:05:00 UTC

[jira] [Created] (FLINK-39524) Integrate OutputWriter into filterAndRewrite flow

Rui Fan created FLINK-39524:
-------------------------------

             Summary: Integrate OutputWriter into filterAndRewrite flow
                 Key: FLINK-39524
                 URL: https://issues.apache.org/jira/browse/FLINK-39524
             Project: Flink
          Issue Type: Sub-task
            Reporter: Rui Fan
            Assignee: Rui Fan


`ChannelStateFilteringHandler.filterAndRewrite()` now pushes filtered bytes directly to `OutputWriter.write()` instead of returning a `List<Buffer>`. `RecoveredChannelStateHandler.recoverWithFiltering()` drops the buffer-return handling, and `SequentialChannelStateReaderImpl` creates one per-task OutputWriter plus per-channel RecoveredBufferStores and orchestrates the shutdown sequence `flush → finishReadRecoveredState → close(blocking drain)`.



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