opt for errorMsg when execute batch in the scene of table not exist

Author: GroundWu

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

@@ -512,16 +512,18 @@ private void executeWithRetries(ObTableOperationResult[] results, Map.Entry<Long
 
         Map<Long, ObPair<ObTableParam, List<ObPair<Integer, ObTableOperation>>>> currentPartitions = new HashMap<>();
         currentPartitions.put(entry.getKey(), entry.getValue());
-
-        while (retryCount < maxRetries && !success) {
+        int errCode = ResultCodes.OB_SUCCESS.errorCode;
+        String errMsg = null;
+        while (retryCount <= maxRetries && !success) {
             boolean allPartitionsSuccess = true;
-
             for (Map.Entry<Long, ObPair<ObTableParam, List<ObPair<Integer, ObTableOperation>>>> currentEntry : currentPartitions.entrySet()) {
                 try {
                     partitionExecute(results, currentEntry);
                 } catch (Exception e) {
                     if (shouldRetry(e)) {
                         retryCount++;
+                        errCode = ((ObTableNeedFetchAllException)e).getErrorCode();
+                        errMsg = e.getMessage();
                         List<ObTableOperation> failedOperations = extractOperations(currentEntry.getValue().getRight());
                         currentPartitions = prepareOperations(failedOperations);
                         allPartitionsSuccess = false;
@@ -538,7 +540,9 @@ private void executeWithRetries(ObTableOperationResult[] results, Map.Entry<Long
         }
 
         if (!success) {
-            throw new ObTableUnexpectedException("Failed to execute operation after retrying " + maxRetries + " times.");
+            errMsg = "Failed to execute operation after retrying " + maxRetries + " times. Last error Msg:" +
+                    "[errCode="+ errCode +"] " + errMsg;
+            throw new ObTableUnexpectedException(errMsg);
         }
     }
 

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

@@ -627,8 +627,9 @@ private void executeWithRetries(
 
         Map<Long, Map<Long, ObPair<ObTableParam, List<ObPair<Integer, ObTableSingleOp>>>>> currentPartitions = new HashMap<>();
         currentPartitions.put(entry.getKey(), entry.getValue());
-
-        while (retryCount < maxRetries && !success) {
+        int errCode = ResultCodes.OB_SUCCESS.errorCode;
+        String errMsg = null;
+        while (retryCount <= maxRetries && !success) {
             boolean allPartitionsSuccess = true;
 
             for (Map.Entry<Long, Map<Long, ObPair<ObTableParam, List<ObPair<Integer, ObTableSingleOp>>>>> currentEntry : currentPartitions.entrySet()) {
@@ -637,6 +638,8 @@ private void executeWithRetries(
                 } catch (Exception e) {
                     if (shouldRetry(e)) {
                         retryCount++;
+                        errCode = ((ObTableNeedFetchAllException)e).getErrorCode();
+                        errMsg = e.getMessage();
                         List<ObTableSingleOp> failedOperations = extractOperations(currentEntry.getValue());
                         currentPartitions = prepareOperations(failedOperations);
                         allPartitionsSuccess = false;
@@ -653,6 +656,8 @@ private void executeWithRetries(
         }
 
         if (!success) {
+            errMsg = "Failed to execute operation after retrying " + maxRetries + " times. Last error Msg:" +
+                    "[errCode="+ errCode +"] " + errMsg;
             throw new ObTableUnexpectedException("Failed to execute operation after retrying " + maxRetries + " times.");
         }
     }