Index: src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java =================================================================== --- src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java (revision 1420135) +++ src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java (working copy) @@ -378,6 +378,9 @@ this.peerClusterZnode, this.position, queueRecovered, currentWALisBeingWrittenTo); this.lastLoggedPosition = this.position; } + if (!gotIOE) { + sleepMultiplier = 1; + } if (sleepForRetries("Nothing to replicate", sleepMultiplier)) { sleepMultiplier++; }