[FLINk-10362] [s3] S3 config loading does not search Hadoop classpath

silenceland · Sep 18, 2018 · 679d887 · 679d887
1 parent 8d842e3
commit 679d887
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...ms/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopConfigLoader.java b/...ms/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopConfigLoader.java
@@ -19,7 +19,6 @@
 package org.apache.flink.runtime.fs.hdfs;
 
 import org.apache.flink.configuration.Configuration;
-import org.apache.flink.runtime.util.HadoopUtils;
 
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -91,7 +90,7 @@ public org.apache.hadoop.conf.Configuration getOrLoadHadoopConfig() {
 
 	// add additional config entries from the Flink config to the Hadoop config
 	private org.apache.hadoop.conf.Configuration loadHadoopConfigFromFlink() {
-		org.apache.hadoop.conf.Configuration hadoopConfig = HadoopUtils.getHadoopConfiguration(flinkConfig);
+		org.apache.hadoop.conf.Configuration hadoopConfig = new org.apache.hadoop.conf.Configuration();
 		for (String key : flinkConfig.keySet()) {
 			for (String prefix : flinkConfigPrefixes) {
 				if (key.startsWith(prefix)) {