diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncRequestFutureImpl.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncRequestFutureImpl.java index 036196e..3ed4049 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncRequestFutureImpl.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncRequestFutureImpl.java @@ -48,6 +48,7 @@ import org.apache.hadoop.hbase.RegionLocations; import org.apache.hadoop.hbase.RetryImmediatelyException; import org.apache.hadoop.hbase.ServerName; import org.apache.hadoop.hbase.TableName; +import org.apache.hadoop.hbase.HConstants; import org.apache.hadoop.hbase.classification.InterfaceAudience; import org.apache.hadoop.hbase.client.backoff.ServerStatistics; import org.apache.hadoop.hbase.client.coprocessor.Batch; @@ -568,7 +569,8 @@ class AsyncRequestFutureImpl implements AsyncRequestFuture { // run all the runnables for (Runnable runnable : runnables) { - if ((--actionsRemaining == 0) && reuseThread) { + if ((--actionsRemaining == 0) && reuseThread + && numAttempt < HConstants.DEFAULT_HBASE_CLIENT_RETRIES_NUMBER) { runnable.run(); } else { try {