Index: hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java =================================================================== --- hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java (revision 1485016) +++ hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java (working copy) @@ -452,14 +452,16 @@ } private void connectToPeers() { + int sleepMultiplier = 1; + // Connect to peer cluster first, unless we have to stop while (this.isActive() && this.currentPeers.size() == 0) { - try { - chooseSinks(); - Thread.sleep(this.sleepForRetries); - } catch (InterruptedException e) { - LOG.error("Interrupted while trying to connect to sinks", e); + chooseSinks(); + if (this.isActive() && this.currentPeers.size() == 0) { + if (sleepForRetries("Waiting for peers", sleepMultiplier)) { + sleepMultiplier++; + } } } }