Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-19816 Refresh repliation sinks on UnknownHostException 

Signed-off-by: tedyu <yuzhihong@gmail.com>
This commit is contained in:
Scott Wilson 2018-01-17 13:18:30 -08:00 committed by tedyu
parent 2e6bec6f2f
commit 779371625b
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/HBaseInterClusterReplicationEndpoint.java
View File

@ -21,6 +21,7 @@ package org.apache.hadoop.hbase.replication.regionserver;
import java.io.IOException; import java.io.IOException;
import java.net.ConnectException; import java.net.ConnectException;
import java.net.SocketTimeoutException; import java.net.SocketTimeoutException;
import java.net.UnknownHostException;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Collections; import java.util.Collections;
import java.util.HashMap; import java.util.HashMap;
@ -402,7 +403,7 @@ public class HBaseInterClusterReplicationEndpoint extends HBaseReplicationEndpoi
"call to the remote cluster timed out, which is usually " + "call to the remote cluster timed out, which is usually " +
"caused by a machine failure or a massive slowdown", "caused by a machine failure or a massive slowdown",
this.socketTimeoutMultiplier); this.socketTimeoutMultiplier);
} else if (ioe instanceof ConnectException) { } else if (ioe instanceof ConnectException || ioe instanceof UnknownHostException) {
LOG.warn("Peer is unavailable, rechecking all sinks: ", ioe); LOG.warn("Peer is unavailable, rechecking all sinks: ", ioe);
replicationSinkMgr.chooseSinks(); replicationSinkMgr.chooseSinks();
} else { } else {