From 80381f39446bab131f5b1f227c98bad97545c4c8 Mon Sep 17 00:00:00 2001
From: Karan Mehta <k.mehta@kmehta-ltm1.internal.salesforce.com>
Date: Mon, 6 Mar 2017 15:56:24 -0800
Subject: [PATCH] HBASE-17698 ReplicationEndpoint choosing sinks

Signed-off-by: Andrew Purtell <apurtell@apache.org>
---
 .../regionserver/HBaseInterClusterReplicationEndpoint.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/HBaseInterClusterReplicationEndpoint.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/HBaseInterClusterReplicationEndpoint.java
index ba12d53258c..97f28b4655a 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/HBaseInterClusterReplicationEndpoint.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/HBaseInterClusterReplicationEndpoint.java
@@ -294,8 +294,8 @@ public class HBaseInterClusterReplicationEndpoint extends HBaseReplicationEndpoi
                 + "Replication cannot proceed without losing data.", sleepMultiplier)) {
               sleepMultiplier++;
             }
-          } else if (ioe instanceof SaslException) {
-            LOG.warn("Peer encountered SaslException, rechecking all sinks: ", ioe);
+          } else {
+            LOG.warn("Peer encountered RemoteException, rechecking all sinks: ", ioe);
             replicationSinkMgr.chooseSinks();
           }
         } else {