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 4ab203b3d8..a8efad69fa 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 @@ -67,6 +67,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; @@ -2257,8 +2258,8 @@ 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);