hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From te...@apache.org
Subject hbase git commit: HBASE-19816 Refresh repliation sinks on UnknownHostException
Date Thu, 18 Jan 2018 00:25:28 GMT
Repository: hbase
Updated Branches:
  refs/heads/branch-2 4476cc196 -> 0f2c1fa06


HBASE-19816 Refresh repliation sinks on UnknownHostException

Signed-off-by: tedyu <yuzhihong@gmail.com>


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

Branch: refs/heads/branch-2
Commit: 0f2c1fa0669aeed066bde4a207809808aa6b0a43
Parents: 4476cc1
Author: Scott Wilson <swilson@siftscience.com>
Authored: Wed Jan 17 13:18:30 2018 -0800
Committer: tedyu <yuzhihong@gmail.com>
Committed: Wed Jan 17 16:25:17 2018 -0800

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


http://git-wip-us.apache.org/repos/asf/hbase/blob/0f2c1fa0/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 40f59b7..5872d08 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
@@ -23,6 +23,7 @@ import org.apache.hbase.thirdparty.com.google.common.annotations.VisibleForTesti
 import java.io.IOException;
 import java.net.ConnectException;
 import java.net.SocketTimeoutException;
+import java.net.UnknownHostException;
 import java.util.ArrayList;
 import java.util.Collections;
 import java.util.HashMap;
@@ -399,7 +400,7 @@ public class HBaseInterClusterReplicationEndpoint extends HBaseReplicationEndpoi
               "call to the remote cluster timed out, which is usually " +
               "caused by a machine failure or a massive slowdown",
               this.socketTimeoutMultiplier);
-          } else if (ioe instanceof ConnectException) {
+          } else if (ioe instanceof ConnectException || ioe instanceof UnknownHostException)
{
             LOG.warn("Peer is unavailable, rechecking all sinks: ", ioe);
             replicationSinkMgr.chooseSinks();
           } else {


Mime
View raw message