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

HBASE-16083 revert Addendum - Joseph discovered the mistake first

This commit is contained in:
tedyu 2016-06-22 17:31:24 -07:00
parent da09fd0781
commit 0ea4d2f461
3 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationStateHBaseImpl.java
View File

@ -81,9 +81,9 @@ public class TestReplicationStateHBaseImpl {
public static void setUpBeforeClass() throws Exception {
utility = new HBaseTestingUtility();
conf = utility.getConfiguration();
conf.setClass("hbase.region.replica.replication.replicationQueues.class",
conf.setClass("hbase.region.replica.replication.ReplicationQueuesType",
TableBasedReplicationQueuesImpl.class, ReplicationQueues.class);
conf.setClass("hbase.region.replica.replication.replicationQueuesClient.class",
conf.setClass("hbase.region.replica.replication.ReplicationQueuesClientType",
TableBasedReplicationQueuesClientImpl.class, ReplicationQueuesClient.class);
utility.startMiniCluster();
zkw = HBaseTestingUtility.getZooKeeperWatcher(utility);

4
hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationTableBase.java
View File

@ -54,9 +54,9 @@ public class TestReplicationTableBase {
utility = new HBaseTestingUtility();
utility.startMiniZKCluster();
conf = utility.getConfiguration();
conf.setClass("hbase.region.replica.replication.replicationQueues.class",
conf.setClass("hbase.region.replica.replication.ReplicationQueuesType",
TableBasedReplicationQueuesImpl.class, ReplicationQueues.class);
conf.setClass("hbase.region.replica.replication.replicationQueuesClient.class",
conf.setClass("hbase.region.replica.replication.ReplicationQueuesClientType",
TableBasedReplicationQueuesClientImpl.class, ReplicationQueuesClient.class);
zkw = HBaseTestingUtility.getZooKeeperWatcher(utility);
utility.waitFor(0, TIME_OUT_MILLIS, new Waiter.ExplainingPredicate<Exception>() {

4
hbase-server/src/test/java/org/apache/hadoop/hbase/replication/regionserver/TestTableBasedReplicationSourceManagerImpl.java
View File

@ -48,9 +48,9 @@ public class TestTableBasedReplicationSourceManagerImpl extends TestReplicationS
conf.setLong("replication.sleep.before.failover", 2000);
conf.setInt("replication.source.maxretriesmultiplier", 10);
conf.setClass("hbase.region.replica.replication.replicationQueues.class",
conf.setClass("hbase.region.replica.replication.ReplicationQueuesType",
TableBasedReplicationQueuesImpl.class, ReplicationQueues.class);
conf.setClass("hbase.region.replica.replication.replicationQueuesClient.class",
conf.setClass("hbase.region.replica.replication.ReplicationQueuesClientType",
TableBasedReplicationQueuesClientImpl.class, ReplicationQueuesClient.class);
utility = new HBaseTestingUtility(conf);
utility.startMiniCluster();