[hbase] branch master updated: HBASE-25837 TestRollingRestart is flaky (#3220)

[niuyulin]

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

niuyulin 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 6cfff27  HBASE-25837 TestRollingRestart is flaky (#3220)
6cfff27 is described below

commit 6cfff27465620112eb308cf881e6321d928743ed
Author: niuyulin <yulin.niu.2...@gmail.com>
AuthorDate: Fri May 7 18:58:45 2021 +0800

    HBASE-25837 TestRollingRestart is flaky (#3220)
    
    Signed-off-by: Duo Zhang <zhang...@apache.org>
---
 .../apache/hadoop/hbase/master/TestRollingRestart.java  | 17 ++++++++++++++++-
 1 file changed, 16 insertions(+), 1 deletion(-)

diff --git 
a/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestRollingRestart.java
 
b/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestRollingRestart.java
index dfadb13..7255c01 100644
--- 
a/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestRollingRestart.java
+++ 
b/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestRollingRestart.java
@@ -38,6 +38,7 @@ import org.apache.hadoop.hbase.TableName;
 import org.apache.hadoop.hbase.client.RegionInfo;
 import org.apache.hadoop.hbase.client.RegionLocator;
 import org.apache.hadoop.hbase.client.Table;
+import org.apache.hadoop.hbase.master.procedure.ServerCrashProcedure;
 import org.apache.hadoop.hbase.testclassification.LargeTests;
 import org.apache.hadoop.hbase.testclassification.MasterTests;
 import org.apache.hadoop.hbase.util.Bytes;
@@ -68,6 +69,7 @@ public class TestRollingRestart {
 
   private static final Logger LOG = 
LoggerFactory.getLogger(TestRollingRestart.class);
 
+  private static HBaseTestingUtility TEST_UTIL;
   @Rule
   public TestName name = new TestName();
 
@@ -89,7 +91,7 @@ public class TestRollingRestart {
     Configuration conf = HBaseConfiguration.create();
     conf.setBoolean(HConstants.HBASE_SPLIT_WAL_COORDINATED_BY_ZK,
         splitWALCoordinatedByZK);
-    HBaseTestingUtility TEST_UTIL = new HBaseTestingUtility(conf);
+    TEST_UTIL = new HBaseTestingUtility(conf);
     StartMiniClusterOption option = StartMiniClusterOption.builder()
         
.numMasters(NUM_MASTERS).numRegionServers(NUM_RS).numDataNodes(NUM_RS).build();
     TEST_UTIL.startMiniCluster(option);
@@ -220,6 +222,16 @@ public class TestRollingRestart {
     TEST_UTIL.shutdownMiniCluster();
   }
 
+  /**
+   * Checks if the SCP of specific dead server has been executed.
+   * @return true if the SCP of specific serverName has been executed, false 
if not
+   */
+  private boolean isDeadServerSCPExecuted(ServerName serverName) throws 
IOException {
+    return TEST_UTIL.getMiniHBaseCluster().getMaster().getProcedures().stream()
+        .anyMatch(p -> p instanceof ServerCrashProcedure
+            && ((ServerCrashProcedure) p).getServerName().equals(serverName));
+  }
+
   private void waitForRSShutdownToStartAndFinish(MasterThread activeMaster,
       ServerName serverName) throws InterruptedException, IOException {
     ServerManager sm = activeMaster.getMaster().getServerManager();
@@ -230,6 +242,9 @@ public class TestRollingRestart {
     }
     log("Server [" + serverName + "] marked as dead, waiting for it to " +
         "finish dead processing");
+
+    TEST_UTIL.waitFor(60000, () -> isDeadServerSCPExecuted(serverName));
+
     while (sm.areDeadServersInProgress()) {
       log("Server [" + serverName + "] still being processed, waiting");
       Thread.sleep(100);