diff --git src/main/java/org/apache/hadoop/hbase/client/HConnectionManager.java src/main/java/org/apache/hadoop/hbase/client/HConnectionManager.java index d857538..ee7429e 100644 --- src/main/java/org/apache/hadoop/hbase/client/HConnectionManager.java +++ src/main/java/org/apache/hadoop/hbase/client/HConnectionManager.java @@ -1156,7 +1156,7 @@ public class HConnectionManager { for (Map tableLocations : cachedRegionLocations.values()) { for (Entry e : tableLocations.entrySet()) { - if (e.getValue().getServerAddress().toString().equals(server)) { + if (e.getValue().getHostnamePort().equals(server)) { tableLocations.remove(e.getKey()); deletedSomething = true; } @@ -1215,7 +1215,7 @@ public class HConnectionManager { getTableLocations(tableName); boolean hasNewCache = false; synchronized (this.cachedRegionLocations) { - cachedServers.add(location.getServerAddress().toString()); + cachedServers.add(location.getHostnamePort()); hasNewCache = (tableLocations.put(startKey, location) == null); } if (hasNewCache) { diff --git src/main/java/org/apache/hadoop/hbase/client/ServerCallable.java src/main/java/org/apache/hadoop/hbase/client/ServerCallable.java index a8adf72..fcf43e7 100644 --- src/main/java/org/apache/hadoop/hbase/client/ServerCallable.java +++ src/main/java/org/apache/hadoop/hbase/client/ServerCallable.java @@ -172,7 +172,7 @@ public abstract class ServerCallable implements Callable { // .META. again to find the new location HRegionLocation hrl = location; if (hrl != null) { - getConnection().clearCaches(hrl.getServerAddress().toString()); + getConnection().clearCaches(hrl.getHostnamePort()); } } RetriesExhaustedException.ThrowableWithExtraContext qt =