Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-21510 Test TestRegisterPeerWorkerWhenRestarting is flakey

This commit is contained in:
zhangduo 2018-11-24 19:50:59 +08:00
parent d9c773b0a5
commit 701526d19f
1 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
hbase-server/src/test/java/org/apache/hadoop/hbase/master/replication/TestRegisterPeerWorkerWhenRestarting.java
View File

@ -19,7 +19,6 @@ package org.apache.hadoop.hbase.master.replication;
import static org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.RecoverStandbyState.DISPATCH_WALS_VALUE; import static org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.RecoverStandbyState.DISPATCH_WALS_VALUE;
import static org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.RecoverStandbyState.UNREGISTER_PEER_FROM_WORKER_STORAGE_VALUE; import static org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.RecoverStandbyState.UNREGISTER_PEER_FROM_WORKER_STORAGE_VALUE;
import static org.junit.Assert.assertEquals;
import java.io.IOException; import java.io.IOException;
import java.io.UncheckedIOException; import java.io.UncheckedIOException;
@ -119,9 +118,9 @@ public class TestRegisterPeerWorkerWhenRestarting extends SyncReplicationTestBas
mt.join(); mt.join();
FAIL = false; FAIL = false;
t.join(); t.join();
// make sure the new master can finish the transiting // make sure the new master can finish the transition
assertEquals(SyncReplicationState.DOWNGRADE_ACTIVE, UTIL2.waitFor(60000, () -> UTIL2.getAdmin()
UTIL2.getAdmin().getReplicationPeerSyncReplicationState(PEER_ID)); .getReplicationPeerSyncReplicationState(PEER_ID) == SyncReplicationState.DOWNGRADE_ACTIVE);
verify(UTIL2, 0, 100); verify(UTIL2, 0, 100);
} }
} }