From 0a25bf5b3fe33ea2b894df06906e4ec1d75ac338 Mon Sep 17 00:00:00 2001
From: Phil Yang <yangzhe1991@apache.org>
Date: Mon, 13 Feb 2017 19:03:27 +0800
Subject: [PATCH] HBASE-17639 Do not stop server if ReplicationSourceManager's
 waitUntilCanBePushed throws InterruptedException

---
 .../hbase/replication/regionserver/ReplicationSource.java    | 5 ++++-
 1 file changed, 4 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 8013a5a7699..ce070d01666 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
@@ -762,9 +762,12 @@ public class ReplicationSource extends Thread
       if (!canSkipWaitingSet.getUnchecked(key)) {
         try {
           manager.waitUntilCanBePushed(Bytes.toBytes(key), seq, actualPeerId);
-        } catch (Exception e) {
+        } catch (IOException e) {
           LOG.error("waitUntilCanBePushed fail", e);
           stopper.stop("waitUntilCanBePushed fail");
+        } catch (InterruptedException e) {
+          LOG.warn("waitUntilCanBePushed interrupted", e);
+          Thread.currentThread().interrupt();
         }
         canSkipWaitingSet.put(key, true);
       }