diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestDFSUtil.java b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestDFSUtil.java index fce57c842fd95..8dc895dc9b8e7 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestDFSUtil.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestDFSUtil.java @@ -555,10 +555,10 @@ public void testHANameNodesWithFederation() throws URISyntaxException { assertTrue(HAUtil.isHAEnabled(conf, "ns2")); assertFalse(HAUtil.isHAEnabled(conf, "ns3")); - assertEquals(NS1_NN1_HOST, map.get("ns1").get("ns1-nn1").toString()); - assertEquals(NS1_NN2_HOST, map.get("ns1").get("ns1-nn2").toString()); - assertEquals(NS2_NN1_HOST, map.get("ns2").get("ns2-nn1").toString()); - assertEquals(NS2_NN2_HOST, map.get("ns2").get("ns2-nn2").toString()); + assertEquals(resolvedName(NS1_NN1_HOST), map.get("ns1").get("ns1-nn1").toString()); + assertEquals(resolvedName(NS1_NN2_HOST), map.get("ns1").get("ns1-nn2").toString()); + assertEquals(resolvedName(NS2_NN1_HOST), map.get("ns2").get("ns2-nn1").toString()); + assertEquals(resolvedName(NS2_NN2_HOST), map.get("ns2").get("ns2-nn2").toString()); assertEquals(NS1_NN1_HOST, DFSUtil.getNamenodeServiceAddr(conf, "ns1", "ns1-nn1")); @@ -634,8 +634,8 @@ public void testGetHaNnHttpAddresses() throws IOException { Map> map = DFSUtilClient.getHaNnWebHdfsAddresses(conf, "webhdfs"); - assertEquals(NS1_NN1_ADDR, map.get("ns1").get("nn1").toString()); - assertEquals(NS1_NN2_ADDR, map.get("ns1").get("nn2").toString()); + assertEquals(resolvedName(NS1_NN1_ADDR), map.get("ns1").get("nn1").toString()); + assertEquals(resolvedName(NS1_NN2_ADDR), map.get("ns1").get("nn2").toString()); } private static Configuration createWebHDFSHAConfiguration(String logicalHostName, String nnaddr1, String nnaddr2) { @@ -1212,4 +1212,11 @@ private void testLazyResolved(boolean isLazy) { }); }); } + + private String resolvedName(String jdk13) { + if (Shell.isJavaVersionAtLeast(14)) { + return jdk13.replaceAll(":", "/:"); + } + return jdk13; + } }