fix

maochongxin · maochongxin · commit e46c25cda7a2 · 2024-10-31T17:31:03.000+08:00
diff --git a/src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/query/AbstractQueryStreamResult.java b/src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/query/AbstractQueryStreamResult.java
@@ -577,6 +577,7 @@ public void executeWithRetry(ObTableClient client,
                 iterator = exceptionHandler.handle(client, maxRetryTimes, tableName, iterator,
                     entry, e, retryTimes);
             }
+            Thread.sleep(client.getRuntimeRetryInterval());
         }
     }
 
@@ -590,7 +591,7 @@ protected Iterator<Map.Entry<Long, ObPair<Long, ObTableParam>>> handleException(
                                                                                                    throws Exception {
 
         if (client.isOdpMode()) {
-            if ((retryTimes - 1) < maxRetryTimes) {
+            if (retryTimes <= maxRetryTimes) {
                 if (e instanceof ObTableException) {
                     logger.warn(
                         "execute while meet Exception, errorCode: {} , errorMsg: {}, try times {}",

Original file line number	Diff line number	Diff line change
`@@ -577,6 +577,7 @@ public void executeWithRetry(ObTableClient client,`
`577`	`577`	`iterator = exceptionHandler.handle(client, maxRetryTimes, tableName, iterator,`
`578`	`578`	`entry, e, retryTimes);`
`579`	`579`	`}`
	`580`	`+ Thread.sleep(client.getRuntimeRetryInterval());`
`580`	`581`	`}`
`581`	`582`	`}`
`582`	`583`
`@@ -590,7 +591,7 @@ protected Iterator<Map.Entry<Long, ObPair<Long, ObTableParam>>> handleException(`
`590`	`591`	`throws Exception {`
`591`	`592`
`592`	`593`	`if (client.isOdpMode()) {`
`593`		`- if ((retryTimes - 1) < maxRetryTimes) {`
	`594`	`+ if (retryTimes <= maxRetryTimes) {`
`594`	`595`	`if (e instanceof ObTableException) {`
`595`	`596`	`logger.warn(`
`596`	`597`	`"execute while meet Exception, errorCode: {} , errorMsg: {}, try times {}",`