From e087a9ef51ac2d48a56ec331a27d779974e13ca5 Mon Sep 17 00:00:00 2001
From: Elliott Clark <eclark@apache.org>
Date: Wed, 22 Jul 2015 14:50:16 -0700
Subject: [PATCH] HBASE-14146 Fix Once replication sees an error it slows down
 forever

---
 .../hbase/replication/regionserver/ReplicationSource.java     | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java
index 3f23837e838..2126f6db6b5 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSource.java
@@ -659,7 +659,7 @@ public class ReplicationSource extends Thread
    * written to when this method was called
    */
   protected void shipEdits(boolean currentWALisBeingWrittenTo, List<WAL.Entry> entries) {
-    int sleepMultiplier = 1;
+    int sleepMultiplier = 0;
     if (entries.isEmpty()) {
       LOG.warn("Was given 0 edits to ship");
       return;
@@ -696,6 +696,8 @@ public class ReplicationSource extends Thread
 
         if (!replicated) {
           continue;
+        } else {
+          sleepMultiplier = Math.max(sleepMultiplier-1, 0);
         }
 
         if (this.lastLoggedPosition != this.repLogReader.getPosition()) {