This is an automated email from the ASF dual-hosted git repository.

liyu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hbase.git


The following commit(s) were added to refs/heads/master by this push:
     new b0c2832b6ec HBASE-26976 Update related comments after HMaster can load 
the live RS infos from local region (#4375)
b0c2832b6ec is described below

commit b0c2832b6ecdf7a72b219cbf81c2ef70a3097579
Author: LiangJun He <2005hit...@163.com>
AuthorDate: Sat Apr 30 10:53:13 2022 +0800

    HBASE-26976 Update related comments after HMaster can load the live RS 
infos from local region (#4375)
    
    Signed-off-by: Duo Zhang <zhang...@apache.org>
    Signed-off-by: Yu Li <l...@apache.org>
---
 .../src/main/java/org/apache/hadoop/hbase/master/HMaster.java  | 10 ++++------
 .../org/apache/hadoop/hbase/master/RegionServerTracker.java    |  2 +-
 2 files changed, 5 insertions(+), 7 deletions(-)

diff --git 
a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java 
b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java
index 91e18a6f88f..b9fa3294b91 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java
@@ -865,8 +865,8 @@ public class HMaster extends 
HBaseServerBase<MasterRpcServices> implements Maste
    * from meta region</li>
    * <li>Start region server tracker, construct the online servers set and 
find out dead servers and
    * schedule SCP for them. The online servers will be constructed by scanning 
zk, and we will also
-   * scan the wal directory to find out possible live region servers, and the 
differences between
-   * these two sets are the dead servers</li>
+   * scan the wal directory and load from master local region to find out 
possible live region servers,
+   * and the differences between these two sets are the dead servers</li>
    * </ol>
    * </li>
    * <li>If this is a new deploy, schedule a InitMetaProcedure to initialize 
meta</li>
@@ -941,8 +941,6 @@ public class HMaster extends 
HBaseServerBase<MasterRpcServices> implements Maste
       this.splitWALManager = new SplitWALManager(this);
     }
 
-
-
     tryMigrateMetaLocationsFromZooKeeper();
 
     createProcedureExecutor();
@@ -963,8 +961,8 @@ public class HMaster extends 
HBaseServerBase<MasterRpcServices> implements Maste
     this.assignmentManager.setupRIT(ritList);
 
     // Start RegionServerTracker with listing of servers found with exiting 
SCPs -- these should
-    // be registered in the deadServers set -- and with the list of 
servernames out on the
-    // filesystem that COULD BE 'alive' (we'll schedule SCPs for each and let 
SCP figure it out).
+    // be registered in the deadServers set -- and the servernames loaded from 
the WAL directory
+    // and master local region that COULD BE 'alive'(we'll schedule SCPs for 
each and let SCP figure it out).
     // We also pass dirs that are already 'splitting'... so we can do some 
checks down in tracker.
     // TODO: Generate the splitting and live Set in one pass instead of two as 
we currently do.
     this.regionServerTracker.upgrade(
diff --git 
a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/RegionServerTracker.java
 
b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/RegionServerTracker.java
index 63a3ec19fac..84192a7e94c 100644
--- 
a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/RegionServerTracker.java
+++ 
b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/RegionServerTracker.java
@@ -129,7 +129,7 @@ public class RegionServerTracker extends ZKListener {
     // '-SPLITTING'. Each splitting server should have a corresponding SCP. 
Log if not.
     splittingServersFromWALDir.stream().filter(s -> 
!deadServersFromPE.contains(s)).
       forEach(s -> LOG.error("{} has no matching ServerCrashProcedure", s));
-    // create ServerNode for all possible live servers from wal directory
+    // create ServerNode for all possible live servers from wal directory and 
master local region
     liveServersBeforeRestart
         .forEach(sn -> 
server.getAssignmentManager().getRegionStates().getOrCreateServer(sn));
     ServerManager serverManager = server.getServerManager();

Reply via email to