[FLINK-9584] Unclosed streams in Bucketing-/RollingSink

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.5.0, 1.6.0
• Fix Version/s: 1.5.2, 1.6.0
• Component/s: Connectors / FileSystem
• Assignee: Sihua Zhou
• Reporter: Chesnay Schepler
• Created: 14/Jun/18 09:26
• Updated: 11/Jul/18 10:07
• Resolved: 11/Jul/18 10:07

Description

There are 4 instances of FSDataOutputStream that are not properly closed in the BucketingSink (2) and RollingSink (2).

 

https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/RollingSink.java#L536

 https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/RollingSink.java#L705

 

https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java#L638

https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java#882

 

Issue Links

• links to: GitHub Pull Request #6164