diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncProcess.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncProcess.java index 6cb6115..b3ba114 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncProcess.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncProcess.java @@ -1107,7 +1107,8 @@ class AsyncProcess { // 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 {