You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2018/09/18 17:54:54 UTC
[flink] 01/04: [FLINk-10362] [s3] S3 config loading does not search
Hadoop classpath
This is an automated email from the ASF dual-hosted git repository.
sewen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 679d887d7bfb4a6510735b39f3afd7599f219b8b
Author: Stephan Ewen <se...@apache.org>
AuthorDate: Thu Sep 13 12:39:21 2018 +0200
[FLINk-10362] [s3] S3 config loading does not search Hadoop classpath
---
.../main/java/org/apache/flink/runtime/fs/hdfs/HadoopConfigLoader.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git a/flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopConfigLoader.java b/flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopConfigLoader.java
index a40e24f..499bb74 100644
--- a/flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopConfigLoader.java
+++ b/flink-filesystems/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 class HadoopConfigLoader {
// 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)) {