diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/namenode/ha/TestObserverReadProxyProvider.java b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/namenode/ha/TestObserverReadProxyProvider.java index 3b1c0139a40d4..74579996fee5f 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/namenode/ha/TestObserverReadProxyProvider.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/namenode/ha/TestObserverReadProxyProvider.java @@ -145,7 +145,7 @@ public ClientProtocol createProxy(Configuration config, InetSocketAddress nnAddr, Class xface, UserGroupInformation ugi, boolean withRetries, AtomicBoolean fallbackToSimpleAuth) { - return proxyMap.get(nnAddr.toString()); + return proxyMap.get(nnAddr.toString().replaceAll("/", "")); } }) { @Override @@ -530,7 +530,8 @@ private void doWrite() throws Exception { } private void assertHandledBy(int namenodeIdx) { - assertEquals(namenodeAddrs[namenodeIdx], proxyProvider.getLastProxy().proxyInfo); + assertEquals(namenodeAddrs[namenodeIdx], + proxyProvider.getLastProxy().proxyInfo.replaceAll("/", "")); } private static void doWrite(ClientProtocol client) throws Exception {