[
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)
