[
https://issues.apache.org/jira/browse/FLINK-39514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18080277#comment-18080277
]
Taranpreet Kaur commented on FLINK-39514:
-----------------------------------------
Hi [~bli] ,
When can we expect the new release of flink-connector-kafka. Please provide any
relevant information if possible.
> 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)
