You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by zh...@apache.org on 2018/01/18 05:29:10 UTC
[14/50] [abbrv] hbase git commit: HBASE-19816 Refresh repliation
sinks on UnknownHostException
HBASE-19816 Refresh repliation sinks on UnknownHostException
Signed-off-by: tedyu <yu...@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/HBASE-19397-branch-2
Commit: 0f2c1fa0669aeed066bde4a207809808aa6b0a43
Parents: 4476cc1
Author: Scott Wilson <sw...@siftscience.com>
Authored: Wed Jan 17 13:18:30 2018 -0800
Committer: tedyu <yu...@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 {