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

HBASE-17675 ReplicationEndpoint should choose new sinks if a SaslException occurs

Browse Source 
Signed-off-by: Andrew Purtell <apurtell@apache.org>
This commit is contained in:
rgidwani 2017-02-21 15:17:21 -08:00 committed by Andrew Purtell
parent d7ffa0013b
commit 3c0750de54
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -56,6 +56,7 @@ import org.apache.hadoop.hbase.util.Bytes;
import org.apache.hadoop.hbase.util.FSUtils; import org.apache.hadoop.hbase.util.FSUtils;
import org.apache.hadoop.hbase.wal.WAL.Entry; import org.apache.hadoop.hbase.wal.WAL.Entry;
import org.apache.hadoop.ipc.RemoteException; import org.apache.hadoop.ipc.RemoteException;
import javax.security.sasl.SaslException;
/** /**
* A {@link org.apache.hadoop.hbase.replication.ReplicationEndpoint} * A {@link org.apache.hadoop.hbase.replication.ReplicationEndpoint}
@ -293,6 +294,9 @@ public class HBaseInterClusterReplicationEndpoint extends HBaseReplicationEndpoi
+ "Replication cannot proceed without losing data.", sleepMultiplier)) { + "Replication cannot proceed without losing data.", sleepMultiplier)) {
sleepMultiplier++; sleepMultiplier++;
} }
} else if (ioe instanceof SaslException) {
LOG.warn("Peer encountered SaslException, rechecking all sinks: ", ioe);
replicationSinkMgr.chooseSinks();
} }
} else { } else {
if (ioe instanceof SocketTimeoutException) { if (ioe instanceof SocketTimeoutException) {