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 1508437) +++ hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java (working copy) @@ -368,6 +368,10 @@ this.replicationQueueInfo.isQueueRecovered(), currentWALisBeingWrittenTo); this.lastLoggedPosition = this.repLogReader.getPosition(); } + // Reset the sleep multiplier if nothing has actually gone wrong + if (!gotIOE) { + sleepMultiplier = 1; + } if (sleepForRetries("Nothing to replicate", sleepMultiplier)) { sleepMultiplier++; }