HBASE-17698 ReplicationEndpoint choosing sinks
Signed-off-by: Andrew Purtell <apurtell@apache.org>
This commit is contained in:
parent
1c4d9c8965
commit
80381f3944
|
@ -294,8 +294,8 @@ 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) {
|
} else {
|
||||||
LOG.warn("Peer encountered SaslException, rechecking all sinks: ", ioe);
|
LOG.warn("Peer encountered RemoteException, rechecking all sinks: ", ioe);
|
||||||
replicationSinkMgr.chooseSinks();
|
replicationSinkMgr.chooseSinks();
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
|
|
Loading…
Reference in New Issue