HDFS-8939. Test(S)WebHdfsFileContextMainOperations failing on branch-2. Contributed by Chris Nauroth.
(cherry picked from commit 9871f57d41
)
This commit is contained in:
parent
53c38cc89a
commit
c2d2c1802a
|
@ -1292,6 +1292,9 @@ Release 2.8.0 - UNRELEASED
|
||||||
HDFS-8964. When validating the edit log, do not read at or beyond the file
|
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)
|
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
|
Release 2.7.2 - UNRELEASED
|
||||||
|
|
||||||
INCOMPATIBLE CHANGES
|
INCOMPATIBLE CHANGES
|
||||||
|
|
|
@ -46,6 +46,19 @@ public class SWebHdfs extends DelegateToFileSystem {
|
||||||
*/
|
*/
|
||||||
SWebHdfs(URI theUri, Configuration conf)
|
SWebHdfs(URI theUri, Configuration conf)
|
||||||
throws IOException, URISyntaxException {
|
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;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -46,6 +46,18 @@ public class WebHdfs extends DelegateToFileSystem {
|
||||||
*/
|
*/
|
||||||
WebHdfs(URI theUri, Configuration conf)
|
WebHdfs(URI theUri, Configuration conf)
|
||||||
throws IOException, URISyntaxException {
|
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;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue