diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/replication/ReplicationPeer.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/replication/ReplicationPeer.java index 1b14dab..dc4da16 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/replication/ReplicationPeer.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/replication/ReplicationPeer.java @@ -73,9 +73,9 @@ public class ReplicationPeer implements Abortable, Closeable { * @param key cluster key used to locate the peer * @param id string representation of this peer's identifier */ - public ReplicationPeer(Configuration conf, String key, String id) throws ReplicationException { + public ReplicationPeer(Configuration conf, String id) throws ReplicationException { this.conf = conf; - this.clusterKey = key; + this.clusterKey = ZKUtil.getZooKeeperClusterKey(conf); this.id = id; try { this.reloadZkWatcher(); diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.java index fb09102..c55129d 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.java @@ -496,7 +496,7 @@ public class ReplicationPeersZKImpl extends ReplicationStateZKBase implements Re } ReplicationPeer peer = - new ReplicationPeer(peerConf, peerId, ZKUtil.getZooKeeperClusterKey(peerConf)); + new ReplicationPeer(peerConf, peerId); try { peer.startStateTracker(this.zookeeper, this.getPeerStateNode(peerId)); } catch (KeeperException e) {