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

Posted to dev@flink.apache.org by "Xin Gao (Jira)" <ji...@apache.org> on 2026/04/21 19:14:00 UTC

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

Xin Gao created FLINK-39514:
-------------------------------

             Summary: 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
            Reporter: Xin Gao


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)