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 2020/07/08 09:53:09 UTC
[flink] branch release-1.10 updated: [FLINK-18501] Use inner class
name for logging scheme mapping when filesystems are instantiated
This is an automated email from the ASF dual-hosted git repository.
uce pushed a commit to branch release-1.10
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.10 by this push:
new 494e8f8 [FLINK-18501] Use inner class name for logging scheme mapping when filesystems are instantiated
494e8f8 is described below
commit 494e8f89395c942b304509023b450c49cf70f13b
Author: Fabian Paul <fa...@ververica.com>
AuthorDate: Mon Jul 6 16:16:25 2020 +0200
[FLINK-18501] Use inner class name for logging scheme mapping when filesystems are instantiated
---
flink-core/src/main/java/org/apache/flink/core/fs/FileSystem.java | 2 +-
.../main/java/org/apache/flink/core/fs/PluginFileSystemFactory.java | 5 +++++
2 files changed, 6 insertions(+), 1 deletion(-)
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 912f134..a0cc635 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
@@ -1023,7 +1023,7 @@ public abstract class FileSystem {
try {
FileSystemFactory factory = iter.next();
list.add(factory);
- LOG.debug("Added file system {}:{}", factory.getScheme(), factory.getClass().getName());
+ LOG.debug("Added file system {}:{}", factory.getScheme(), factory.toString());
}
catch (Throwable t) {
// catching Throwable here to handle various forms of class loading
diff --git a/flink-core/src/main/java/org/apache/flink/core/fs/PluginFileSystemFactory.java b/flink-core/src/main/java/org/apache/flink/core/fs/PluginFileSystemFactory.java
index 3cff358..39a9828 100644
--- a/flink-core/src/main/java/org/apache/flink/core/fs/PluginFileSystemFactory.java
+++ b/flink-core/src/main/java/org/apache/flink/core/fs/PluginFileSystemFactory.java
@@ -62,6 +62,11 @@ public class PluginFileSystemFactory implements FileSystemFactory {
}
}
+ @Override
+ public String toString() {
+ return String.format("Plugin %s", inner.getClass().getName());
+ }
+
static class ClassLoaderFixingFileSystem extends FileSystem {
private final FileSystem inner;
private final ClassLoader loader;