diff --git a/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt b/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt index afc6cf49d5f..42460ed9ba2 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt +++ b/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt @@ -1292,6 +1292,9 @@ Release 2.8.0 - UNRELEASED HDFS-8964. When validating the edit log, do not read at or beyond the file offset that is being written (Zhe Zhang via Colin P. McCabe) + HDFS-8939. Test(S)WebHdfsFileContextMainOperations failing on branch-2. + (Chris Nauroth via jghoman) + Release 2.7.2 - UNRELEASED INCOMPATIBLE CHANGES diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/fs/SWebHdfs.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/fs/SWebHdfs.java index cd363936e31..04b5880d947 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/fs/SWebHdfs.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/fs/SWebHdfs.java @@ -46,6 +46,19 @@ public class SWebHdfs extends DelegateToFileSystem { */ SWebHdfs(URI theUri, Configuration conf) throws IOException, URISyntaxException { - super(theUri, new SWebHdfsFileSystem(), conf, SCHEME, false); + super(theUri, createSWebHdfsFileSystem(conf), conf, SCHEME, false); + } + + /** + * Returns a new {@link SWebHdfsFileSystem}, with the given configuration. + * + * @param conf configuration + * @return new SWebHdfsFileSystem + */ + private static SWebHdfsFileSystem createSWebHdfsFileSystem( + Configuration conf) { + SWebHdfsFileSystem fs = new SWebHdfsFileSystem(); + fs.setConf(conf); + return fs; } } diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/fs/WebHdfs.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/fs/WebHdfs.java index dc4f6d55688..d54a6b30eff 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/fs/WebHdfs.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/fs/WebHdfs.java @@ -46,6 +46,18 @@ public class WebHdfs extends DelegateToFileSystem { */ WebHdfs(URI theUri, Configuration conf) throws IOException, URISyntaxException { - super(theUri, new WebHdfsFileSystem(), conf, SCHEME, false); + super(theUri, createWebHdfsFileSystem(conf), conf, SCHEME, false); + } + + /** + * Returns a new {@link WebHdfsFileSystem}, with the given configuration. + * + * @param conf configuration + * @return new WebHdfsFileSystem + */ + private static WebHdfsFileSystem createWebHdfsFileSystem(Configuration conf) { + WebHdfsFileSystem fs = new WebHdfsFileSystem(); + fs.setConf(conf); + return fs; } }