Github user steveloughran commented on a diff in the pull request:
https://github.com/apache/flink/pull/4926#discussion_r148328550
--- Diff:
flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/util/HadoopUtils.java
---
@@ -44,7 +44,9 @@
public static Configuration
getHadoopConfiguration(org.apache.flink.configuration.Configuration
flinkConfiguration) {
- Configuration result = new Configuration();
+ // the HdfsConfiguration adds per default hdfs-site.xml and
hdfs-default.xml
+ // as a default resource which is read from the class path
+ Configuration result = new HdfsConfiguration();
--- End diff --
It's not mandatory to load in HDFSConfiguration, as trying to connect to
HDFS via FileSystem.get(hdfs://) kicks all this off.
---
