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

HBASE-26884 Find unavailable regions by the startcode checking on hmaster start up and reassign them

This commit is contained in:
bsglz 2022-03-25 17:42:49 +08:00
parent 4ac600b04b
commit 5102fea7d4
1 changed files with 23 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
hbase-server/src/main/java/org/apache/hadoop/hbase/master/assignment/AssignmentManager.java
View File

@ -1696,7 +1696,29 @@ public class AssignmentManager {
if (localState.matches(State.OPEN, State.OPENING, State.CLOSING, State.SPLITTING,
State.MERGING)) {
assert regionLocation != null : "found null region location for " + regionNode;
regionStates.addRegionToServer(regionNode);
// If the startcode of the regionLocation expired, and neither TRSP on region nor SCP on
// regionserver, then we should reassign the region
boolean startcodeExpired = false;
if (localState.matches(State.OPEN, State.OPENING) && regionNode.getProcedure() == null
&& !getMaster().getServerManager().getDeadServers().isDeadServer(regionLocation)) {
List<ServerName> serverNames = getMaster().getServerManager().getOnlineServersList();
for (ServerName sn : serverNames) {
if (regionLocation.getHostname().equals(sn.getHostname())
&& regionLocation.getPort() == sn.getPort()
&& regionLocation.getStartcode() < sn.getStartcode()) {
startcodeExpired = true;
break;
}
}
}
if (startcodeExpired) {
LOG.warn("The startcode of regionLocation expired, reassign the region {}", regionNode);
regionNode.setState(State.OFFLINE);
regionStates.addToOfflineRegions(regionNode);
} else {
regionStates.addRegionToServer(regionNode);
}
} else if (localState == State.OFFLINE || regionInfo.isOffline()) {
regionStates.addToOfflineRegions(regionNode);
}