[fix][sdk] Adjusting the retryTimes for REQUEST_FULL errors

DataCanvasIO · Apr 26, 2024 · ee2709d · ee2709d
1 parent 50eb368
commit ee2709d
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 0 deletions.
diff --git a/java/dingo-sdk/src/main/java/io/dingodb/sdk/service/caller/ServiceCaller.java b/java/dingo-sdk/src/main/java/io/dingodb/sdk/service/caller/ServiceCaller.java
@@ -75,6 +75,7 @@ public <REQ extends Request, RES extends Response> RES call(
         Map<String, Integer> errMsgs = new HashMap<>();
         String methodName = method.getFullMethodName();
         REQ lastRequest = null;
+        boolean specialRetry = true;
         while (retry-- > 0) {
             try {
                 if (channel == null) {
@@ -104,6 +105,10 @@ public <REQ extends Request, RES extends Response> RES call(
                             if (errCode == Errno.ERAFT_NOTLEADER.number) {
                                 channel = updateChannel(channel, requestId);
                             } else {
+                                if (errCode == Errno.EREQUEST_FULL.number && specialRetry) {
+                                    retry = 3600;
+                                    specialRetry = false;
+                                }
                                 waitRetry();
                             }
                             continue;

diff --git a/java/dingo-sdk/src/main/java/io/dingodb/sdk/service/connector/ServiceConnector.java b/java/dingo-sdk/src/main/java/io/dingodb/sdk/service/connector/ServiceConnector.java
@@ -16,6 +16,7 @@
 
 package io.dingodb.sdk.service.connector;
 
+import io.dingodb.error.ErrorOuterClass;
 import io.dingodb.sdk.common.DingoClientException;
 import io.dingodb.sdk.common.DingoClientException.InvalidRouteTableException;
 import io.dingodb.sdk.common.DingoClientException.RequestErrorException;
@@ -181,6 +182,7 @@ public <R> Response<R> exec(
 
         S stub = null;
         boolean connected = false;
+        boolean specialRetry = true;
         Map<String, Integer> errMsgs = new HashMap<>();
 
         while (retryTimes-- > 0) {
@@ -202,6 +204,10 @@ public <R> Response<R> exec(
                         case RETRY:
                             errorLog(name, authority, error, RETRY);
                             LockSupport.parkNanos(TimeUnit.SECONDS.toNanos(1));
+                            if (errCode == ErrorOuterClass.Errno.EREQUEST_FULL_VALUE && specialRetry) {
+                                retryTimes = 3600;
+                                specialRetry = false;
+                            }
                             refresh(stub);
                             continue;
                         case FAILED: