diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/ProtobufUtil.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/ProtobufUtil.java index a619e39cd6a6..0d1a201c32d2 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/ProtobufUtil.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/ProtobufUtil.java @@ -3460,7 +3460,7 @@ public static RSGroupInfo toGroupInfo(RSGroupProtos.RSGroupInfo proto) { RSGroupInfo rsGroupInfo = new RSGroupInfo(proto.getName()); Collection
addresses = proto.getServersList().parallelStream() - .map(serverName -> Address.fromParts(serverName.getHostName(), serverName.getPort())) + .map(serverName -> Address.fromParts(serverName.getHostName().toLowerCase(Locale.ROOT), serverName.getPort())) .collect(Collectors.toList()); rsGroupInfo.addAllServers(addresses); diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/rsgroup/RSGroupAdminServiceImpl.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/rsgroup/RSGroupAdminServiceImpl.java index 35824fd36332..7e5fefe58d3a 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/rsgroup/RSGroupAdminServiceImpl.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/rsgroup/RSGroupAdminServiceImpl.java @@ -22,6 +22,7 @@ import java.util.HashMap; import java.util.HashSet; import java.util.List; +import java.util.Locale; import java.util.Map; import java.util.Optional; import java.util.Set; @@ -162,7 +163,7 @@ public void moveServers(RpcController controller, MoveServersRequest request, MoveServersResponse.Builder builder = MoveServersResponse.newBuilder(); Set
hostPorts = Sets.newHashSet(); for (HBaseProtos.ServerName el : request.getServersList()) { - hostPorts.add(Address.fromParts(el.getHostName(), el.getPort())); + hostPorts.add(Address.fromParts(el.getHostName().toLowerCase(Locale.ROOT), el.getPort())); } LOG.info(master.getClientIdAuditPrefix() + " move servers " + hostPorts + " to rsgroup " + request.getTargetGroup()); @@ -357,7 +358,7 @@ public void moveServersAndTables(RpcController controller, MoveServersAndTablesR MoveServersAndTablesResponse.Builder builder = MoveServersAndTablesResponse.newBuilder(); Set
hostPorts = Sets.newHashSet(); for (HBaseProtos.ServerName el : request.getServersList()) { - hostPorts.add(Address.fromParts(el.getHostName(), el.getPort())); + hostPorts.add(Address.fromParts(el.getHostName().toLowerCase(Locale.ROOT), el.getPort())); } Set tables = new HashSet<>(request.getTableNameList().size()); for (HBaseProtos.TableName tableName : request.getTableNameList()) { @@ -388,7 +389,7 @@ public void removeServers(RpcController controller, RemoveServersRequest request RemoveServersResponse.Builder builder = RemoveServersResponse.newBuilder(); Set
servers = Sets.newHashSet(); for (HBaseProtos.ServerName el : request.getServersList()) { - servers.add(Address.fromParts(el.getHostName(), el.getPort())); + servers.add(Address.fromParts(el.getHostName().toLowerCase(Locale.ROOT), el.getPort())); } LOG.info( master.getClientIdAuditPrefix() + " remove decommissioned servers from rsgroup: " + servers); diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/rsgroup/RSGroupInfoManagerImpl.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/rsgroup/RSGroupInfoManagerImpl.java index 5332c6e84506..64bb899d0f69 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/rsgroup/RSGroupInfoManagerImpl.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/rsgroup/RSGroupInfoManagerImpl.java @@ -760,7 +760,7 @@ private SortedSet
getDefaultServers(List rsGroupInfoList) // Get all online servers from Zookeeper and find out servers in default group SortedSet
defaultServers = Sets.newTreeSet(); for (ServerName serverName : masterServices.getServerManager().getOnlineServers().keySet()) { - Address server = Address.fromParts(serverName.getHostname(), serverName.getPort()); + Address server = Address.fromParts(serverName.getHostnameLowerCase(), serverName.getPort()); if (!serversInOtherGroup.contains(server)) { // not in other groups defaultServers.add(server); }