You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by uc...@apache.org on 2016/12/13 12:53:39 UTC
flink git commit: [FLINK-5328] [logging] Add Thread name to
FileSystem disposeFileSystemCloseableRegistryForTask
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 <uc...@apache.org>
Authored: Tue Dec 13 13:51:34 2016 +0100
Committer: Ufuk Celebi <uc...@apache.org>
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);
}