You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@hbase.apache.org by jd...@apache.org on 2013/08/07 18:29:41 UTC

svn commit: r1511378 - /hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java

Author: jdcryans
Date: Wed Aug  7 16:29:41 2013
New Revision: 1511378

URL: http://svn.apache.org/r1511378
Log:
HBASE-7325 Replication reacts slowly on a lightly-loaded cluster (Gabriel Reid via JD)

Modified:
    hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java

Modified: hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java
URL: http://svn.apache.org/viewvc/hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java?rev=1511378&r1=1511377&r2=1511378&view=diff
==============================================================================
--- hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java (original)
+++ hbase/trunk/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java Wed Aug  7 16:29:41 2013
@@ -336,6 +336,10 @@ public class ReplicationSource extends T
               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++;
         }