diff --git src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java index fd5ffe2..fe5b8e9 100644 --- src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java +++ src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java @@ -221,7 +221,7 @@ public class ReplicationSource extends Thread List addresses = this.zkHelper.getSlavesAddresses(peerId); Set setOfAddr = new HashSet(); int nbPeers = (int) (Math.ceil(addresses.size() * ratio)); - LOG.info("Getting " + nbPeers + + LOG.debug("Getting " + nbPeers + " rs from peer cluster # " + peerId); for (int i = 0; i < nbPeers; i++) { ServerName sn;