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 1381352) +++ hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java (working copy) @@ -139,6 +139,8 @@ private volatile boolean running = true; // Metrics for this source private ReplicationSourceMetrics metrics; + // The current sleep multiplier + private int sleepMultiplier; /** * Instantiation method used by region servers @@ -248,7 +250,7 @@ metrics.clear(); return; } - int sleepMultiplier = 1; + sleepMultiplier = 1; // delay this until we are in an asynchronous thread while (this.peerClusterId == null) { this.peerClusterId = zkHelper.getPeerUUID(this.peerId); @@ -466,6 +468,7 @@ try { if (this.currentPath == null) { this.currentPath = queue.poll(this.sleepForRetries, TimeUnit.MILLISECONDS); + this.sleepMultiplier = 1; this.metrics.setSizeOfLogQueue(queue.size()); } } catch (InterruptedException e) { @@ -692,6 +695,7 @@ protected boolean processEndOfFile() { if (this.queue.size() != 0) { this.currentPath = null; + this.sleepMultiplier = 1; this.position = 0; return true; } else if (this.queueRecovered) {