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); }