flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-4910) Introduce safety net for closing file system streams
Date Thu, 27 Oct 2016 13:29:58 GMT

    [ https://issues.apache.org/jira/browse/FLINK-4910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15611886#comment-15611886

ASF GitHub Bot commented on FLINK-4910:

Github user StephanEwen commented on a diff in the pull request:

    --- Diff: flink-core/src/main/java/org/apache/flink/core/fs/AbstractCloseableRegistry.java
    @@ -16,29 +16,29 @@
      * limitations under the License.
    -package org.apache.flink.runtime.state;
    +package org.apache.flink.core.fs;
    --- End diff --
    Since this is used for other things than filesystems, how about moving it to `org.apache.flink.core.util`?

> Introduce safety net for closing file system streams
> ----------------------------------------------------
>                 Key: FLINK-4910
>                 URL: https://issues.apache.org/jira/browse/FLINK-4910
>             Project: Flink
>          Issue Type: Improvement
>            Reporter: Stefan Richter
>            Assignee: Stefan Richter
> Streams that are opened through {{FileSystem}} must be closed at the end of their life
cycle. However, we found hints that some code forgets to close such streams.
> We should introduce i) a mechanism that closes leaking unclosed streams after usage and
ii) provides logging that helps us to track down and fi the sources of such leaks.

This message was sent by Atlassian JIRA

View raw message