From fa7444f6df9d1e03883da4eecdb9529579cc11e0 Mon Sep 17 00:00:00 2001 From: zhangduo Date: Sat, 24 Nov 2018 16:49:01 +0800 Subject: [PATCH] HBASE-21510 Test TestRegisterPeerWorkerWhenRestarting is flakey --- .../replication/TestRegisterPeerWorkerWhenRestarting.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/master/replication/TestRegisterPeerWorkerWhenRestarting.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/master/replication/TestRegisterPeerWorkerWhenRestarting.java index 72aa32d22e..84f3362619 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/master/replication/TestRegisterPeerWorkerWhenRestarting.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/master/replication/TestRegisterPeerWorkerWhenRestarting.java @@ -119,9 +119,9 @@ public class TestRegisterPeerWorkerWhenRestarting extends SyncReplicationTestBas mt.join(); FAIL = false; t.join(); - // make sure the new master can finish the transiting - assertEquals(SyncReplicationState.DOWNGRADE_ACTIVE, - UTIL2.getAdmin().getReplicationPeerSyncReplicationState(PEER_ID)); + // make sure the new master can finish the transition + UTIL2.waitFor(60000, () -> UTIL2.getAdmin() + .getReplicationPeerSyncReplicationState(PEER_ID) == SyncReplicationState.DOWNGRADE_ACTIVE); verify(UTIL2, 0, 100); } } -- 2.17.1