[jira] [Commented] (FLINK-23248) SinkWriter is not closed when failing
[ 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)
[jira] [Commented] (FLINK-23248) SinkWriter is not closed when failing
[ 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)
