gaborgsomogyi commented on code in PR #20011:
URL: https://github.com/apache/flink/pull/20011#discussion_r901835791
##########
flink-core/src/main/java/org/apache/flink/core/fs/FileSystem.java:
##########
@@ -527,13 +527,30 @@ public static FileSystem getUnguardedFileSystem(final URI
fsUri) throws IOExcept
try {
fs = FALLBACK_FACTORY.create(uri);
} catch (UnsupportedFileSystemSchemeException e) {
- throw new UnsupportedFileSystemSchemeException(
- "Could not find a file system implementation for
scheme '"
- + uri.getScheme()
- + "'. The scheme is not directly supported
by Flink and no Hadoop file system to "
- + "support this scheme could be loaded.
For a full list of supported file systems, "
- + "please see
https://nightlies.apache.org/flink/flink-docs-stable/ops/filesystems/.";,
- e);
+ if
(DIRECTLY_SUPPORTED_FILESYSTEM.containsKey(uri.getScheme())) {
+ final Collection<String> plugins =
+
DIRECTLY_SUPPORTED_FILESYSTEM.get(uri.getScheme());
+ throw new UnsupportedFileSystemSchemeException(
+ String.format(
+ "Could not find a file system
implementation for scheme '%s'. The scheme is "
+ + "directly supported by Flink
through the following plugin%s: %s "
Review Comment:
Changed.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
