diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java index af661a281d..e93b728574 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java @@ -77,6 +77,7 @@ import org.apache.hadoop.hbase.HealthCheckChore; import org.apache.hadoop.hbase.MetaTableAccessor; import org.apache.hadoop.hbase.NotServingRegionException; import org.apache.hadoop.hbase.PleaseHoldException; +import org.apache.hadoop.hbase.CallQueueTooBigException; import org.apache.hadoop.hbase.ScheduledChore; import org.apache.hadoop.hbase.ServerName; import org.apache.hadoop.hbase.Stoppable; @@ -2361,8 +2362,9 @@ public class HRegionServer extends HasThread implements return true; } catch (ServiceException se) { IOException ioe = ProtobufUtil.getRemoteException(se); - boolean pause = ioe instanceof ServerNotRunningYetException || - ioe instanceof PleaseHoldException; + boolean pause = + ioe instanceof ServerNotRunningYetException || ioe instanceof PleaseHoldException + || ioe instanceof CallQueueTooBigException; if (pause) { // Do backoff else we flood the Master with requests. pauseTime = ConnectionUtils.getPauseTime(INIT_PAUSE_TIME_MS, tries);