You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by zh...@apache.org on 2026/01/09 10:05:49 UTC
(hbase) branch branch-2.5 updated: HBASE-29817 Stop retrying on DoNotRetryIOException when waiting procedure result (#7610)
This is an automated email from the ASF dual-hosted git repository.
zhangduo pushed a commit to branch branch-2.5
in repository https://gitbox.apache.org/repos/asf/hbase.git
The following commit(s) were added to refs/heads/branch-2.5 by this push:
new 2d325ed4237 HBASE-29817 Stop retrying on DoNotRetryIOException when waiting procedure result (#7610)
2d325ed4237 is described below
commit 2d325ed4237eab4e230ce78ea78a529dfdc392dd
Author: Duo Zhang <zh...@apache.org>
AuthorDate: Fri Jan 9 17:37:21 2026 +0800
HBASE-29817 Stop retrying on DoNotRetryIOException when waiting procedure result (#7610)
Signed-off-by: Hui Ruan <hu...@apache.org>
Reviewed-by: Umesh Kumar <94...@gmail.com>
Reviewed-by: Liu Xiao <li...@qq.com>
(cherry picked from commit 9e3b53cfcb13552726f57dab45ce337bef5c8032)
---
.../apache/hadoop/hbase/client/RawAsyncHBaseAdmin.java | 15 +++++++++++----
1 file changed, 11 insertions(+), 4 deletions(-)
diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RawAsyncHBaseAdmin.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RawAsyncHBaseAdmin.java
index 41b1cc69f2d..02d5aaae247 100644
--- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RawAsyncHBaseAdmin.java
+++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RawAsyncHBaseAdmin.java
@@ -54,6 +54,7 @@ import org.apache.hadoop.hbase.CacheEvictionStatsAggregator;
import org.apache.hadoop.hbase.ClusterMetrics;
import org.apache.hadoop.hbase.ClusterMetrics.Option;
import org.apache.hadoop.hbase.ClusterMetricsBuilder;
+import org.apache.hadoop.hbase.DoNotRetryIOException;
import org.apache.hadoop.hbase.HConstants;
import org.apache.hadoop.hbase.HRegionLocation;
import org.apache.hadoop.hbase.MetaTableAccessor;
@@ -2809,10 +2810,16 @@ class RawAsyncHBaseAdmin implements AsyncAdmin {
.call(),
(response, error) -> {
if (error != null) {
- LOG.warn("failed to get the procedure result procId={}", procId,
- ConnectionUtils.translateException(error));
- retryTimer.newTimeout(t -> getProcedureResult(procId, future, retries + 1),
- ConnectionUtils.getPauseTime(pauseNs, retries), TimeUnit.NANOSECONDS);
+ Throwable exc = ConnectionUtils.translateException(error);
+ if (exc instanceof DoNotRetryIOException) {
+ // stop retrying on DNRIOE
+ future.completeExceptionally(exc);
+ } else {
+ LOG.warn("failed to get the procedure result procId={}", procId, exc);
+ retryTimer.newTimeout(t -> getProcedureResult(procId, future, retries + 1),
+ ConnectionUtils.getPauseTime(pauseNs, retries), TimeUnit.NANOSECONDS);
+
+ }
return;
}
if (response.getState() == GetProcedureResultResponse.State.RUNNING) {