From 2aa7078a1a00dfa11d64ff3f18341be083f2f93f Mon Sep 17 00:00:00 2001
From: mazhengxuan <1319614897@qq.com>
Date: Fri, 28 Aug 2026 00:06:49 +0800
Subject: [PATCH] HBASE-30344 Wait for RegionServer sync replication state

---
 .../replication/TestSyncReplicationStandbyKillMaster.java     | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestSyncReplicationStandbyKillMaster.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestSyncReplicationStandbyKillMaster.java
index 5074279b7bee..79ad621917d9 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestSyncReplicationStandbyKillMaster.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestSyncReplicationStandbyKillMaster.java
@@ -108,6 +108,10 @@ public void testStandbyKillMaster() throws Exception {
     await().atMost(Duration.ofMinutes(3))
       .untilAsserted(() -> assertEquals(SyncReplicationState.DOWNGRADE_ACTIVE,
         UTIL2.getAdmin().getReplicationPeerSyncReplicationState(PEER_ID)));
+    await().atMost(Duration.ofMinutes(3))
+      .untilAsserted(() -> assertEquals(SyncReplicationState.DOWNGRADE_ACTIVE,
+        UTIL2.getRSForFirstRegionInTable(TABLE_NAME).getReplicationSourceService()
+          .getReplicationPeers().getPeer(PEER_ID).getSyncReplicationState()));
 
     verify(UTIL2, 0, COUNT);
   }