Fix batch wait (#278)

* remove unnecessary sleep * fix log arg
oceanbase · Jan 9, 2025 · 857e829 · 857e829
1 parent 642ad45
commit 857e829
Show file tree

Hide file tree

Showing 3 changed files with 1 addition and 3 deletions.
diff --git a/...m/alipay/oceanbase/rpc/protocol/payload/impl/execute/query/AbstractQueryStreamResult.java b/...m/alipay/oceanbase/rpc/protocol/payload/impl/execute/query/AbstractQueryStreamResult.java
@@ -257,7 +257,7 @@ protected ObPayload commonExecute(ObTableClient client, Logger logger,
                                 }
                             } else {
                                 String logMessage = String.format(
-                                        "exhaust retry while meet NeedRefresh Exception, table name: %s, ls id: %d, batch ops refresh table, errorCode: %d",
+                                        "exhaust retry while meet NeedRefresh Exception, table name: %s, batch ops refresh table, errorCode: %d",
                                         indexTableName,
                                         ((ObTableException) e).getErrorCode()
                                 );

diff --git a/src/main/java/com/alipay/oceanbase/rpc/table/ObTableClientBatchOpsImpl.java b/src/main/java/com/alipay/oceanbase/rpc/table/ObTableClientBatchOpsImpl.java
@@ -539,7 +539,6 @@ private void executeWithRetries(ObTableOperationResult[] results, Map.Entry<Long
                         throw e;
                     }
                 }
-                Thread.sleep(obTableClient.getRuntimeRetryInterval());
             }
 
             if (allPartitionsSuccess) {

diff --git a/src/main/java/com/alipay/oceanbase/rpc/table/ObTableClientLSBatchOpsImpl.java b/src/main/java/com/alipay/oceanbase/rpc/table/ObTableClientLSBatchOpsImpl.java
@@ -702,7 +702,6 @@ private void executeWithRetries(
                         throw e;
                     }
                 }
-                Thread.sleep(obTableClient.getRuntimeRetryInterval());
             }
 
             if (allPartitionsSuccess) {
-Original file line number
+Diff line change
@@ Expand Up @@
                             throw e;
                         }
                     }
-                    Thread.sleep(obTableClient.getRuntimeRetryInterval());
                 }
                 if (allPartitionsSuccess) {
@@ Expand Down @@