Repository: flink Updated Branches: refs/heads/master 81d8fe16a -> fc627232c
[FLINK-5328] [logging] Add Thread name to FileSystem disposeFileSystemCloseableRegistryForTask Adding this to the FileSystem dispose call in order to help debugging FLINK-5328 when it occurs again. After the initial skim over the logs it looks like the streams are closed to early for the failed task. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fc627232 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/fc627232 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/fc627232 Branch: refs/heads/master Commit: fc627232c80bc2bf7669c064bef725f2466955f5 Parents: 81d8fe1 Author: Ufuk Celebi <[email protected]> Authored: Tue Dec 13 13:51:34 2016 +0100 Committer: Ufuk Celebi <[email protected]> Committed: Tue Dec 13 13:53:30 2016 +0100 ---------------------------------------------------------------------- flink-core/src/main/java/org/apache/flink/core/fs/FileSystem.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/fc627232/flink-core/src/main/java/org/apache/flink/core/fs/FileSystem.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/core/fs/FileSystem.java b/flink-core/src/main/java/org/apache/flink/core/fs/FileSystem.java index 5a608b5..433cec0 100644 --- a/flink-core/src/main/java/org/apache/flink/core/fs/FileSystem.java +++ b/flink-core/src/main/java/org/apache/flink/core/fs/FileSystem.java @@ -83,7 +83,7 @@ public abstract class FileSystem { public static void disposeFileSystemCloseableRegistryForTask() { SafetyNetCloseableRegistry registry = REGISTRIES.get(); if (null != registry) { - LOG.info("Ensuring all FileSystem streams are closed"); + LOG.info("Ensuring all FileSystem streams are closed for {}", Thread.currentThread().getName()); REGISTRIES.remove(); IOUtils.closeQuietly(registry); }
