[
https://issues.apache.org/jira/browse/FLINK-37612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan reassigned FLINK-37612:
-----------------------------------------
Assignee: Roman Khachatryan
> 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
> Assignee: Roman Khachatryan
> Priority: Major
>
> 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)
