[ https://issues.apache.org/jira/browse/FLINK-9584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Chesnay Schepler closed FLINK-9584. ----------------------------------- Resolution: Fixed master: 04a7cd4d9232e757560e156a684e224d54b71176 1.5: d3b644a0e006352880cb7c613cdab6ea86c45719 > Unclosed streams in Bucketing-/RollingSink > ------------------------------------------ > > Key: FLINK-9584 > URL: https://issues.apache.org/jira/browse/FLINK-9584 > Project: Flink > Issue Type: Bug > Components: filesystem-connector > Affects Versions: 1.5.0, 1.6.0 > Reporter: Chesnay Schepler > Assignee: Sihua Zhou > Priority: Major > Fix For: 1.5.2, 1.6.0 > > > 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] > -- This message was sent by Atlassian JIRA (v7.6.3#76005)