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

@@ -514,16 +514,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;
@@ -540,7 +542,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

@@ -630,7 +630,8 @@ private void executeWithRetries(
 
         Map<Long, Map<Long, ObPair<ObTableParam, List<ObPair<Integer, ObTableSingleOp>>>>> currentPartitions = new HashMap<>();
         currentPartitions.put(entry.getKey(), entry.getValue());
-
+        int errCode = ResultCodes.OB_SUCCESS.errorCode;
+        String errMsg = null;
         while (retryCount <= maxRetries && !success) {
             boolean allPartitionsSuccess = true;
 
@@ -640,6 +641,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;
@@ -656,6 +659,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.");
         }
     }