HBASE-19816 Refresh repliation sinks on UnknownHostException Signed-off-by: tedyu <yuzhih...@gmail.com>
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/e3d15834 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/e3d15834 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/e3d15834 Branch: refs/heads/HBASE-19064 Commit: e3d15834cb50b4d93373de7d4f7aa43173dfcc39 Parents: b1729a2 Author: Scott Wilson <swil...@siftscience.com> Authored: Wed Jan 17 13:18:30 2018 -0800 Committer: tedyu <yuzhih...@gmail.com> Committed: Wed Jan 17 16:24:48 2018 -0800 ---------------------------------------------------------------------- .../regionserver/HBaseInterClusterReplicationEndpoint.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/e3d15834/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 1ef1198..49ea1f7 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 @@ -21,6 +21,7 @@ package org.apache.hadoop.hbase.replication.regionserver; 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; @@ -398,7 +399,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 {
