[ https://issues.apache.org/jira/browse/FLINK-23248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17375344#comment-17375344 ]
Arvid Heise commented on FLINK-23248: ------------------------------------- Merged into 1.13 as 9d77656381f55d05a3eb74c6c6c6de873de2b7c7, into 1.12 as 701d20e896112b64d3a2dad9bb7e2e976bc88cb1. > SinkWriter is not closed when failing > ------------------------------------- > > Key: FLINK-23248 > URL: https://issues.apache.org/jira/browse/FLINK-23248 > Project: Flink > Issue Type: Bug > Components: Runtime / Task > Affects Versions: 1.13.1, 1.12.4 > Reporter: Fabian Paul > Assignee: Fabian Paul > Priority: Critical > Labels: pull-request-available > > Currently the SinkWriter is only closed when the operator finishes in > `AbstractSinkWriterOperator#close()` but we also must close the SinkWrite on > `AbstractSinkWriterOperator#dispose()` to release possible acquired resources > when failing > > -- This message was sent by Atlassian Jira (v8.3.4#803005)