hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From apurt...@apache.org
Subject [1/5] hbase git commit: HBASE-17698 ReplicationEndpoint choosing sinks
Date Fri, 31 Mar 2017 23:32:11 GMT
Repository: hbase
Updated Branches:
  refs/heads/branch-1 cc700ef4c -> 19e4e4d49
  refs/heads/branch-1.1 1fdb97ce8 -> 575a8c909
  refs/heads/branch-1.2 2d79b7d5a -> cd583383b
  refs/heads/branch-1.3 36da029ed -> ea3907da7
  refs/heads/master 1c4d9c896 -> 80381f394


HBASE-17698 ReplicationEndpoint choosing sinks

Signed-off-by: Andrew Purtell <apurtell@apache.org>


Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/80381f39
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/80381f39
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/80381f39

Branch: refs/heads/master
Commit: 80381f39446bab131f5b1f227c98bad97545c4c8
Parents: 1c4d9c8
Author: Karan Mehta <k.mehta@kmehta-ltm1.internal.salesforce.com>
Authored: Mon Mar 6 15:56:24 2017 -0800
Committer: Andrew Purtell <apurtell@apache.org>
Committed: Fri Mar 31 16:12:10 2017 -0700

----------------------------------------------------------------------
 .../regionserver/HBaseInterClusterReplicationEndpoint.java       | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hbase/blob/80381f39/hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/HBaseInterClusterReplicationEndpoint.java
----------------------------------------------------------------------
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 ba12d53..97f28b4 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 {


Mime
View raw message