diff --git a/src/main/java/org/apache/hadoop/hbase/catalog/CatalogTracker.java b/src/main/java/org/apache/hadoop/hbase/catalog/CatalogTracker.java index b58cdb5..f72b431 100644 --- a/src/main/java/org/apache/hadoop/hbase/catalog/CatalogTracker.java +++ b/src/main/java/org/apache/hadoop/hbase/catalog/CatalogTracker.java @@ -22,6 +22,7 @@ package org.apache.hadoop.hbase.catalog; import java.io.EOFException; import java.io.IOException; import java.net.ConnectException; +import java.net.SocketTimeoutException; import java.util.concurrent.atomic.AtomicBoolean; import org.apache.commons.logging.Log; @@ -390,7 +391,9 @@ public class CatalogTracker { } } catch (IOException ioe) { Throwable cause = ioe.getCause(); - if (cause != null && cause instanceof EOFException) { + if (ioe instanceof SocketTimeoutException) { + // Catch. Other end not found + } else if (cause != null && cause instanceof EOFException) { // Catch. Other end disconnected us. } else if (cause != null && cause.getMessage() != null && cause.getMessage().toLowerCase().contains("connection reset")) {