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

Posted to issues@flink.apache.org by "Bowen Li (Jira)" <ji...@apache.org> on 2026/04/24 16:17:00 UTC

[jira] [Resolved] (FLINK-39514) Dynamic Kafka source readers do not release splits after removal

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

Bowen Li resolved FLINK-39514.
------------------------------
    Resolution: Fixed

> Dynamic Kafka source readers do not release splits after removal
> ----------------------------------------------------------------
>
>                 Key: FLINK-39514
>                 URL: https://issues.apache.org/jira/browse/FLINK-39514
>             Project: Flink
>          Issue Type: Bug
>          Components: Connectors / Kafka
>            Reporter: Xin Gao
>            Assignee: Xin Gao
>            Priority: Critical
>              Labels: pull-request-available
>
> DynamicKafkaSourceReader filtered removed cluster/topic splits out of reader state and closed sub-readers, but did not call {{{}ReaderOutput.releaseOutputForSplit(...){}}}. Flink keeps split-local outputs registered for watermark aggregation until they are explicitly released, so removed Kafka splits could continue holding back the source watermark indefinitely. ([Flink code link|https://github.com/apache/flink/blob/master/flink-core/src/main/java/org/apache/flink/api/connector/source/ReaderOutput.java#L103])



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