diff --git hbase-client/src/main/java/org/apache/hadoop/hbase/client/ServerCallable.java hbase-client/src/main/java/org/apache/hadoop/hbase/client/ServerCallable.java index bbffd97..042c01b 100644 --- hbase-client/src/main/java/org/apache/hadoop/hbase/client/ServerCallable.java +++ hbase-client/src/main/java/org/apache/hadoop/hbase/client/ServerCallable.java @@ -28,6 +28,7 @@ import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.HConstants; import org.apache.hadoop.hbase.HRegionLocation; import org.apache.hadoop.hbase.exceptions.DoNotRetryIOException; +import org.apache.hadoop.hbase.exceptions.NotServingRegionException; import org.apache.hadoop.hbase.ipc.HBaseClientRPC; import org.apache.hadoop.hbase.util.Bytes; import org.apache.hadoop.hbase.util.EnvironmentEdgeManager; @@ -175,6 +176,7 @@ public abstract class ServerCallable implements Callable { if (t instanceof SocketTimeoutException || t instanceof ConnectException || + t instanceof NotServingRegionException || t instanceof RetriesExhaustedException || getConnection().isDeadServer(location.getServerName())) { // if thrown these exceptions, we clear all the cache entries that