Arvid Heise created FLINK-37612:
-----------------------------------
Summary: Exception during initialization may leave operator
unclosed
Key: FLINK-37612
URL: https://issues.apache.org/jira/browse/FLINK-37612
Project: Flink
Issue Type: Bug
Components: Runtime / Task
Affects Versions: 2.0.0
Reporter: Arvid Heise
While working on Kafka connector, I noticed that KafkaSinkIT#rescaleListing
reliably produces a resource leak. The respective code path aborts two
transactions in initializeState but may get interrupted for some reason
(probably cancellation). At that point, SinkWriterOperator#close was never
called, leaking producers.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
