Skip to content

Commit

Permalink
HBASE-27717 Add rsgroup name for dead region servers on master UI (#5330
Browse files Browse the repository at this point in the history
)

Co-authored-by: xieyupei <xieyupei@meituan.com>
Signed-off-by: Xiaolin Ha <haxiaolin@apache.org>
Signed-off-by: Duo Zhang <zhangduo@apache.org>
  • Loading branch information
xieyupei and xieyupei committed Aug 13, 2023
1 parent 00be2a5 commit 712254b
Showing 1 changed file with 23 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -52,6 +52,7 @@ org.apache.hadoop.hbase.master.RegionState;
org.apache.hadoop.hbase.master.ServerManager;
org.apache.hadoop.hbase.quotas.QuotaUtil;
org.apache.hadoop.hbase.rsgroup.RSGroupInfoManager;
org.apache.hadoop.hbase.rsgroup.RSGroupInfo;
org.apache.hadoop.hbase.rsgroup.RSGroupUtil;
org.apache.hadoop.hbase.security.access.PermissionStorage;
org.apache.hadoop.hbase.security.visibility.VisibilityConstants;
Expand Down Expand Up @@ -698,17 +699,35 @@ AssignmentManager assignmentManager = master.getAssignmentManager();
<th></th>
<th>ServerName</th>
<th>Stop time</th>
<%if !master.isInMaintenanceMode() && master.getMasterCoprocessorHost() != null %>
<%if RSGroupUtil.isRSGroupEnabled(master.getConfiguration()) %>
<th>RSGroup</th>
</%if>
</%if>
</tr>
<%java>
DeadServer deadServerUtil = master.getServerManager().getDeadServers();
ServerName [] deadServerNames = deadServers.toArray(new ServerName[deadServers.size()]);
Arrays.sort(deadServerNames);
for (ServerName deadServerName: deadServerNames) {
RSGroupInfoManager inMgr = null;
DeadServer deadServerUtil = master.getServerManager().getDeadServers();
ServerName [] deadServerNames = deadServers.toArray(new ServerName[deadServers.size()]);
Arrays.sort(deadServerNames);
if (!master.isInMaintenanceMode() && master.getMasterCoprocessorHost() != null
&& RSGroupUtil.isRSGroupEnabled(master.getConfiguration())) {
inMgr = master.getRSGroupInfoManager();
}
for (ServerName deadServerName: deadServerNames) {
String rsGroupName = null;
if (inMgr != null){
RSGroupInfo groupInfo = inMgr.getRSGroupOfServer(deadServerName.getAddress());
rsGroupName = groupInfo == null ? RSGroupInfo.DEFAULT_GROUP : groupInfo.getName();
}
</%java>
<tr>
<th></th>
<td><% deadServerName %></td>
<td><% deadServerUtil.getTimeOfDeath(deadServerName) %></td>
<%if rsGroupName != null %>
<td><% rsGroupName %></td>
</%if>
</tr>
<%java>
}
Expand Down

0 comments on commit 712254b

Please sign in to comment.