@@ -555,10 +555,10 @@ public void testHANameNodesWithFederation() throws URISyntaxException {
555
555
assertTrue (HAUtil .isHAEnabled (conf , "ns2" ));
556
556
assertFalse (HAUtil .isHAEnabled (conf , "ns3" ));
557
557
558
- assertEquals (NS1_NN1_HOST , map .get ("ns1" ).get ("ns1-nn1" ).toString ());
559
- assertEquals (NS1_NN2_HOST , map .get ("ns1" ).get ("ns1-nn2" ).toString ());
560
- assertEquals (NS2_NN1_HOST , map .get ("ns2" ).get ("ns2-nn1" ).toString ());
561
- assertEquals (NS2_NN2_HOST , map .get ("ns2" ).get ("ns2-nn2" ).toString ());
558
+ assertEquals (resolvedName ( NS1_NN1_HOST ) , map .get ("ns1" ).get ("ns1-nn1" ).toString ());
559
+ assertEquals (resolvedName ( NS1_NN2_HOST ) , map .get ("ns1" ).get ("ns1-nn2" ).toString ());
560
+ assertEquals (resolvedName ( NS2_NN1_HOST ) , map .get ("ns2" ).get ("ns2-nn1" ).toString ());
561
+ assertEquals (resolvedName ( NS2_NN2_HOST ) , map .get ("ns2" ).get ("ns2-nn2" ).toString ());
562
562
563
563
assertEquals (NS1_NN1_HOST ,
564
564
DFSUtil .getNamenodeServiceAddr (conf , "ns1" , "ns1-nn1" ));
@@ -634,8 +634,8 @@ public void testGetHaNnHttpAddresses() throws IOException {
634
634
Map <String , Map <String , InetSocketAddress >> map =
635
635
DFSUtilClient .getHaNnWebHdfsAddresses (conf , "webhdfs" );
636
636
637
- assertEquals (NS1_NN1_ADDR , map .get ("ns1" ).get ("nn1" ).toString ());
638
- assertEquals (NS1_NN2_ADDR , map .get ("ns1" ).get ("nn2" ).toString ());
637
+ assertEquals (resolvedName ( NS1_NN1_ADDR ) , map .get ("ns1" ).get ("nn1" ).toString ());
638
+ assertEquals (resolvedName ( NS1_NN2_ADDR ) , map .get ("ns1" ).get ("nn2" ).toString ());
639
639
}
640
640
641
641
private static Configuration createWebHDFSHAConfiguration (String logicalHostName , String nnaddr1 , String nnaddr2 ) {
@@ -1212,4 +1212,11 @@ private void testLazyResolved(boolean isLazy) {
1212
1212
});
1213
1213
});
1214
1214
}
1215
+
1216
+ private String resolvedName (String jdk13 ) {
1217
+ if (Shell .isJavaVersionAtLeast (14 )) {
1218
+ return jdk13 .replaceAll (":" , "/<unresolved>:" );
1219
+ }
1220
+ return jdk13 ;
1221
+ }
1215
1222
}
0 commit comments