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 1386822) +++ hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java (working copy) @@ -283,8 +283,13 @@ } continue; } + Path oldPath = getCurrentPath(); + boolean pathNull = getNextPath(); + if (getCurrentPath() != null && !getCurrentPath().equals(oldPath)) { + sleepMultiplier = 1; //reset the sleepMultiplier on a path change + } // Get a new path - if (!getNextPath()) { + if (!pathNull) { if (sleepForRetries("No log to process", sleepMultiplier)) { sleepMultiplier++; }