Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/6149#discussion_r195345480
--- Diff:
flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/util/HadoopUtils.java
---
@@ -122,4 +125,28 @@ public static boolean hasHDFSDelegationToken() throws
Exception {
}
return false;
}
+
+ /**
+ * Parse configuration and load the limited FS wrapper.
+ */
+ public static FileSystem limitIfConfigured(FileSystem fs, String
scheme, org.apache.flink.configuration.Configuration config) {
--- End diff --
```
public static FileSystem limitIfConfigured(
FileSystem fs,
String scheme,
Optional<org.apache.flink.configuration.Configuration> config) {
if (!config.isPresent()) {
return fs;
}
....
```
---
