Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-24675: On Master restart all servers are assigned to default rsgroup 

Closes #2102

Signed-off-by: Viraj Jasani <vjasani@apache.org>
This commit is contained in:
Mohammad Arshad 2020-07-20 19:05:50 +05:30 committed by Viraj Jasani
parent fb0fb58677
commit d697c4061a
No known key found for this signature in database
GPG Key ID: B3D6C0B41C8ADFD5
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
hbase-rsgroup/src/main/java/org/apache/hadoop/hbase/rsgroup/RSGroupInfoManagerImpl.java
View File

@ -333,7 +333,7 @@ public class RSGroupInfoManagerImpl implements RSGroupInfoManager, ServerListene
// so it overwrites the default group loaded
// from region group table or zk
groupList.add(new RSGroupInfo(RSGroupInfo.DEFAULT_GROUP,
Sets.newHashSet(getDefaultServers()),
Sets.newHashSet(getDefaultServers(groupList)),
orphanTables));
// populate the data
@ -479,9 +479,13 @@ public class RSGroupInfoManagerImpl implements RSGroupInfoManager, ServerListene
}
private List<Address> getDefaultServers() throws IOException {
return getDefaultServers(listRSGroups() /* get from rsGroupMap */);
}
private List<Address> getDefaultServers(List<RSGroupInfo> rsGroupInfoList) throws IOException {
// Build a list of servers in other groups than default group, from rsGroupMap
Set<Address> serverAddressesInOtherGroups = new HashSet<>();
for (RSGroupInfo group : listRSGroups() /* get from rsGroupMap */) {
for (RSGroupInfo group : rsGroupInfoList) {
if (!RSGroupInfo.DEFAULT_GROUP.equals(group.getName())) { // not default group
serverAddressesInOtherGroups.addAll(group.getServers());
}