[
https://issues.apache.org/jira/browse/FLINK-23248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17375336#comment-17375336
]
Fabian Paul commented on FLINK-23248:
-------------------------------------
In Flink 1.14.0 the issue is resolved by
https://issues.apache.org/jira/browse/FLINK-22972
> 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)
