diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/zookeeper/ReadOnlyZKClient.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/zookeeper/ReadOnlyZKClient.java index a1475de8a1e..0447e31fdd0 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/zookeeper/ReadOnlyZKClient.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/zookeeper/ReadOnlyZKClient.java @@ -86,7 +86,7 @@ public final class ReadOnlyZKClient implements Closeable { public void exec(ZooKeeper zk) { } - public void connectFailed(IOException e) { + public void connectFailed(Exception e) { } public void closed(IOException e) { @@ -233,7 +233,7 @@ public final class ReadOnlyZKClient implements Closeable { } @Override - public void connectFailed(IOException e) { + public void connectFailed(Exception e) { if (delay(retryIntervalMs, maxRetries)) { LOG.warn("{} to {} failed to connect to zk fo {} of {}, retries = {}", getId(), connectString, operationType, path, retries, e); @@ -341,7 +341,7 @@ public final class ReadOnlyZKClient implements Closeable { ZooKeeper zk; try { zk = getZk(); - } catch (IOException e) { + } catch (Exception e) { task.connectFailed(e); continue; }