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

HBASE-10335 AuthFailedException in zookeeper may block replication forever (Liu Shaohui) 

git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1558300 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
liangxie 2014-01-15 05:57:11 +00:00
parent d6f2301f2a
commit 0fc32e203a
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
hbase-client/src/main/java/org/apache/hadoop/hbase/replication/ReplicationPeersZKImpl.java
View File

@ -42,6 +42,7 @@ import org.apache.hadoop.hbase.zookeeper.ZKUtil;
import org.apache.hadoop.hbase.zookeeper.ZooKeeperListener; import org.apache.hadoop.hbase.zookeeper.ZooKeeperListener;
import org.apache.hadoop.hbase.zookeeper.ZooKeeperWatcher; import org.apache.hadoop.hbase.zookeeper.ZooKeeperWatcher;
import org.apache.zookeeper.KeeperException; import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.KeeperException.AuthFailedException;
import org.apache.zookeeper.KeeperException.ConnectionLossException; import org.apache.zookeeper.KeeperException.ConnectionLossException;
import org.apache.zookeeper.KeeperException.SessionExpiredException; import org.apache.zookeeper.KeeperException.SessionExpiredException;
@ -226,6 +227,9 @@ public class ReplicationPeersZKImpl extends ReplicationStateZKBase implements Re
try { try {
addresses = fetchSlavesAddresses(peer.getZkw()); addresses = fetchSlavesAddresses(peer.getZkw());
} catch (KeeperException ke) { } catch (KeeperException ke) {
if (LOG.isDebugEnabled()) {
LOG.debug("Fetch salves addresses failed.", ke);
}
reconnectPeer(ke, peer); reconnectPeer(ke, peer);
addresses = Collections.emptyList(); addresses = Collections.emptyList();
} }
@ -332,7 +336,8 @@ public class ReplicationPeersZKImpl extends ReplicationStateZKBase implements Re
* @param peer * @param peer
*/ */
private void reconnectPeer(KeeperException ke, ReplicationPeer peer) { private void reconnectPeer(KeeperException ke, ReplicationPeer peer) {
if (ke instanceof ConnectionLossException || ke instanceof SessionExpiredException) { if (ke instanceof ConnectionLossException || ke instanceof SessionExpiredException
|| ke instanceof AuthFailedException) {
LOG.warn("Lost the ZooKeeper connection for peer " + peer.getClusterKey(), ke); LOG.warn("Lost the ZooKeeper connection for peer " + peer.getClusterKey(), ke);
try { try {
peer.reloadZkWatcher(); peer.reloadZkWatcher();
@ -491,4 +496,4 @@ public class ReplicationPeersZKImpl extends ReplicationStateZKBase implements Re
} }
} }
} }