From a6788c0b48633f6c7e9c58d55f40d039f83c9c53 Mon Sep 17 00:00:00 2001 From: Karan Mehta Date: Mon, 6 Mar 2017 15:56:24 -0800 Subject: [PATCH] HBASE-17698 ReplicationEndpoint choosing sinks --- .../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 de3159f..7a8c1d8 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 { -- 2.10.1 (Apple Git-78)