fix: truncate retry fail

Author: maochongxin

src/main/java/com/alipay/oceanbase/rpc/ObTableClient.java

@@ -128,7 +128,7 @@ public class ObTableClient extends AbstractObTableClient implements Lifecycle {
     /*
      * TableName -> Failures/Lock
      */
-    public ConcurrentHashMap<String, AtomicLong>             tableContinuousFailures                 = new ConcurrentHashMap<String, AtomicLong>();
+    private ConcurrentHashMap<String, AtomicLong>             tableContinuousFailures                 = new ConcurrentHashMap<String, AtomicLong>();
 
     private ConcurrentHashMap<String, Lock>                   refreshTableLocks                       = new ConcurrentHashMap<String, Lock>();
 
@@ -788,6 +788,13 @@ public void calculateContinuousFailure(String tableName, String errorMsg) throws
         }
     }
 
+    public void resetContinuousFailureByTableName(String tableName) {
+        tableContinuousFailures.computeIfPresent(tableName, (k, v) -> {
+            v.set(0);
+            return v;
+        });
+    }
+
     /**
      * Reset execute continuous failure count.
      * @param tableName table name

src/main/java/com/alipay/oceanbase/rpc/table/ObTableClientBatchOpsImpl.java

@@ -385,10 +385,8 @@ public void partitionExecute(ObTableOperationResult[] results,
                         if (ex instanceof ObTableRoutingWrongException) {
                             System.out.println("need fetchAll refresh");
                             obTableClient.getOrRefreshTableEntry(tableName, true, obTableClient.isTableEntryRefreshIntervalWait(), true);
-                            obTableClient.tableContinuousFailures.computeIfPresent(tableName, (k, v) -> {
-                                v.set(0);
-                                return v;
-                            });
+                            // reset failure count while fetch all route info
+                            obTableClient.resetContinuousFailureByTableName(tableName);
                         }
                     } else {
                         obTableClient.calculateContinuousFailure(tableName, ex.getMessage());