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)
