[ https://issues.apache.org/jira/browse/FLINK-23248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Fabian Paul updated FLINK-23248: -------------------------------- Affects Version/s: (was: 1.14.0) > 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)