svn merge -c 1443297 from trunk for HDFS-4458. In DFSUtil.getNameServiceUris(..), convert default fs URI using NetUtils.createSocketAddr(..) for being consistent with other addresses.
git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/branches/branch-2@1443300 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
94cf1d319e
commit
0caafb63ef
|
@ -12,6 +12,10 @@ Release 2.0.4-beta - UNRELEASED
|
||||||
|
|
||||||
BUG FIXES
|
BUG FIXES
|
||||||
|
|
||||||
|
HDFS-4458. In DFSUtil.getNameServiceUris(..), convert default fs URI using
|
||||||
|
NetUtils.createSocketAddr(..) for being consistent with other addresses.
|
||||||
|
(Binglin Chang via szetszwo)
|
||||||
|
|
||||||
Release 2.0.3-alpha - 2013-02-06
|
Release 2.0.3-alpha - 2013-02-06
|
||||||
|
|
||||||
INCOMPATIBLE CHANGES
|
INCOMPATIBLE CHANGES
|
||||||
|
|
|
@ -764,6 +764,13 @@ public class DFSUtil {
|
||||||
|
|
||||||
// Add the default URI if it is an HDFS URI.
|
// Add the default URI if it is an HDFS URI.
|
||||||
URI defaultUri = FileSystem.getDefaultUri(conf);
|
URI defaultUri = FileSystem.getDefaultUri(conf);
|
||||||
|
// checks if defaultUri is ip:port format
|
||||||
|
// and convert it to hostname:port format
|
||||||
|
if (defaultUri != null && (defaultUri.getPort() != -1)) {
|
||||||
|
defaultUri = createUri(defaultUri.getScheme(),
|
||||||
|
NetUtils.createSocketAddr(defaultUri.getHost(),
|
||||||
|
defaultUri.getPort()));
|
||||||
|
}
|
||||||
if (defaultUri != null &&
|
if (defaultUri != null &&
|
||||||
HdfsConstants.HDFS_URI_SCHEME.equals(defaultUri.getScheme()) &&
|
HdfsConstants.HDFS_URI_SCHEME.equals(defaultUri.getScheme()) &&
|
||||||
!nonPreferredUris.contains(defaultUri)) {
|
!nonPreferredUris.contains(defaultUri)) {
|
||||||
|
|
|
@ -619,6 +619,16 @@ public class TestDFSUtil {
|
||||||
|
|
||||||
assertEquals(1, uris.size());
|
assertEquals(1, uris.size());
|
||||||
assertTrue(uris.contains(new URI("hdfs://" + NN1_SRVC_ADDR)));
|
assertTrue(uris.contains(new URI("hdfs://" + NN1_SRVC_ADDR)));
|
||||||
|
|
||||||
|
// Make sure when config FS_DEFAULT_NAME_KEY using IP address,
|
||||||
|
// it will automatically convert it to hostname
|
||||||
|
conf = new HdfsConfiguration();
|
||||||
|
conf.set(CommonConfigurationKeys.FS_DEFAULT_NAME_KEY, "hdfs://127.0.0.1:8020");
|
||||||
|
uris = DFSUtil.getNameServiceUris(conf);
|
||||||
|
assertEquals(1, uris.size());
|
||||||
|
for (URI uri : uris) {
|
||||||
|
assertFalse(uri.getHost().equals("127.0.0.1"));
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
|
|
Loading…
Reference in New Issue