diff --git a/hbase-rsgroup/src/test/java/org/apache/hadoop/hbase/rsgroup/TestRSGroupsBase.java b/hbase-rsgroup/src/test/java/org/apache/hadoop/hbase/rsgroup/TestRSGroupsBase.java index a725134..5b5802a 100644 --- a/hbase-rsgroup/src/test/java/org/apache/hadoop/hbase/rsgroup/TestRSGroupsBase.java +++ b/hbase-rsgroup/src/test/java/org/apache/hadoop/hbase/rsgroup/TestRSGroupsBase.java @@ -486,8 +486,17 @@ public abstract class TestRSGroupsBase { ((ClusterConnection) admin.getConnection()).getAdmin(targetServer); //move target server to group - rsGroupAdmin.moveServers(Sets.newHashSet(targetServer.getHostPort()), - newGroup.getName()); + final int NUM_RETRIES = 3; + for (int i = 0; i < NUM_RETRIES; i++) { + try { + rsGroupAdmin.moveServers(Sets.newHashSet(targetServer.getHostPort()), + newGroup.getName()); + } catch (Exception e) { + if (i >= NUM_RETRIES-1) { + throw e; + } + } + } TEST_UTIL.waitFor(WAIT_TIMEOUT, new Waiter.Predicate() { @Override public boolean evaluate() throws Exception {