huaxiangsun commented on a change in pull request #1924:
URL: https://github.com/apache/hbase/pull/1924#discussion_r443727313
##########
File path:
hbase-server/src/main/java/org/apache/hadoop/hbase/master/assignment/TransitRegionStateProcedure.java
##########
@@ -338,6 +345,35 @@ protected Flow executeFromState(MasterProcedureEnv env,
RegionStateTransitionSta
try {
switch (state) {
case REGION_STATE_TRANSITION_GET_ASSIGN_CANDIDATE:
+
+ // Need to do some sanity check for replica region, if the region
does not exist at file
+ // system, do not try to assign the replica region, log error and
return.
+ // Do not rely on master's in-memory state, primary region got its
own life, it can be
+ // closed, offline for various reasons.
+ if (!RegionReplicaUtil.isDefaultReplica(regionNode.getRegionInfo()))
{
+ MasterFileSystem mfs =
env.getMasterServices().getMasterFileSystem();
+ RegionInfo replicaRI = regionNode.getRegionInfo();
+ Path tableDir = CommonFSUtils.getTableDir(mfs.getRootDir(),
regionNode.getTable());
+ Path regionDir = FSUtils.getRegionDirFromTableDir(tableDir,
replicaRI);
+ FileSystem fs = mfs.getFileSystem();
+ // Check if primary region directory exists
+ if (!fs.exists(regionDir)) {
+ LOG.error(
+ "Cannot assign replica region {} because its primary region {}
does not exist"
+ + " at Filesystem", replicaRI,
+
ServerRegionReplicaUtil.getRegionInfoForDefaultReplica(replicaRI));
+ return Flow.NO_MORE_STATE;
+ }
+ // check if .regionInfo exists in primary region
+ Path regionInfoFile = new Path(regionDir,
HRegionFileSystem.REGION_INFO_FILE);
+ if (!fs.exists(regionInfoFile)) {
+ LOG.error(
+ "Cannot assign replica region {} because region info file does
not exist in its"
+ + " primary region {}", replicaRI,
+
ServerRegionReplicaUtil.getRegionInfoForDefaultReplica(replicaRI));
+ return Flow.NO_MORE_STATE;
+ }
+ }
Review comment:
Yeah, this is planned. Hbck2 needs work to fix any inconsistency for
read replica, including but not limited to 1). Check consistency for replica
regions (holes/overlaps). Jiras need to be created.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
