HBASE-16083 Addendum fixes config property names in tests

This commit is contained in:
tedyu 2016-06-22 16:35:37 -07:00
parent 2766e4a42e
commit da09fd0781
3 changed files with 6 additions and 6 deletions

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.ReplicationQueuesType",
conf.setClass("hbase.region.replica.replication.replicationQueues.class",
TableBasedReplicationQueuesImpl.class, ReplicationQueues.class);
conf.setClass("hbase.region.replica.replication.ReplicationQueuesClientType",
conf.setClass("hbase.region.replica.replication.replicationQueuesClient.class",
TableBasedReplicationQueuesClientImpl.class, ReplicationQueuesClient.class);
utility.startMiniCluster();
zkw = HBaseTestingUtility.getZooKeeperWatcher(utility);

View File

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

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.ReplicationQueuesType",
conf.setClass("hbase.region.replica.replication.replicationQueues.class",
TableBasedReplicationQueuesImpl.class, ReplicationQueues.class);
conf.setClass("hbase.region.replica.replication.ReplicationQueuesClientType",
conf.setClass("hbase.region.replica.replication.replicationQueuesClient.class",
TableBasedReplicationQueuesClientImpl.class, ReplicationQueuesClient.class);
utility = new HBaseTestingUtility(conf);
utility.startMiniCluster();