From 9871f57d41990b2763d4c23d9040aeb685b4a80f Mon Sep 17 00:00:00 2001 From: Jakob Homan Date: Thu, 3 Sep 2015 13:25:53 -0700 Subject: [PATCH] HDFS-8939. Test(S)WebHdfsFileContextMainOperations failing on branch-2. Contributed by Chris Nauroth. --- hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt | 3 +++ .../main/java/org/apache/hadoop/fs/SWebHdfs.java | 15 ++++++++++++++- .../main/java/org/apache/hadoop/fs/WebHdfs.java | 14 +++++++++++++- 3 files changed, 30 insertions(+), 2 deletions(-) diff --git a/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt b/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt index da6cf24d369..ecc65cc0faf 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt +++ b/hadoop-hdfs-project/hadoop-hdfs/CHANGES.txt @@ -948,6 +948,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; } }