diff --git hbase-client/src/main/java/org/apache/hadoop/hbase/zookeeper/ZKUtil.java hbase-client/src/main/java/org/apache/hadoop/hbase/zookeeper/ZKUtil.java index d3c39e5..6048edd 100644 --- hbase-client/src/main/java/org/apache/hadoop/hbase/zookeeper/ZKUtil.java +++ hbase-client/src/main/java/org/apache/hadoop/hbase/zookeeper/ZKUtil.java @@ -1853,6 +1853,12 @@ public class ZKUtil { try { data = ZKUtil.getData(zkw, znode); } catch(KeeperException e) { + if (e instanceof KeeperException.ConnectionLossException + || e instanceof KeeperException.SessionExpiredException + || e instanceof KeeperException.AuthFailedException) { + // non-recoverable errors so stop here + throw new InterruptedException("interrupted due to " + e); + } LOG.warn("Unexpected exception handling blockUntilAvailable", e); }