protected static void restartSourceCluster(int numSlaves) throws Exception {
    Closeables.close(hbaseAdmin, true);
    Closeables.close(htable1, true);
    UTIL1.shutdownMiniHBaseCluster();
    UTIL1.restartHBaseCluster(numSlaves);
    // Invalidate the cached connection state.
    CONF1 = UTIL1.getConfiguration();
    hbaseAdmin = UTIL1.getAdmin();
    Connection connection1 = UTIL1.getConnection();
    htable1 = connection1.getTable(tableName);
  }
This class is only a base for other integration-level replication tests. Do not add tests here.
TestReplicationSmallTests is where tests that don't require bring machines up/down should go All
other tests should have their own classes and extend this one
hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationBase.java