[FLINK-23248] SinkWriter is not closed when failing

• Type: Bug
• Status: Resolved
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 1.13.1, 1.12.4
• Fix Version/s: 1.12.5, 1.13.2
• Component/s: Runtime / Task
• Labels: pull-request-available
• Assignee: Fabian Paul
• Reporter: Fabian Paul
• Created: 05/Jul/21 08:55
• Updated: 23/Sep/21 17:56
• Resolved: 06/Jul/21 08:16

Description

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

 

 

Issue Links

• links to: GitHub Pull Request #16373
• links to: GitHub Pull Request #16375
• links to: GitHub Pull Request #16376