refresh batch tablet locations when drop table using lsbatch, use runtimeBatchMaxWait to retry lsbatch

Author: JackShi148

src/main/java/com/alipay/oceanbase/rpc/exception/ObTableNeedFetchMetaException.java

@@ -73,6 +73,7 @@ public boolean isNeedRefreshMetaAndLocation() {
                || getErrorCode() == ResultCodes.OB_SNAPSHOT_DISCARDED.errorCode // fetch a wrong ls tablets, need to refetch locations
                || getErrorCode() == ResultCodes.OB_TABLET_NOT_EXIST.errorCode
                || getErrorCode() == ResultCodes.OB_ERR_OPERATION_ON_RECYCLE_OBJECT.errorCode // table has been drop and recreated
-               || getErrorCode() == ResultCodes.OB_MAPPING_BETWEEN_TABLET_AND_LS_NOT_EXIST.errorCode;
+               || getErrorCode() == ResultCodes.OB_MAPPING_BETWEEN_TABLET_AND_LS_NOT_EXIST.errorCode
+               || getErrorCode() == ResultCodes.OB_SCHEMA_ERROR.errorCode; // drop table
     }
 }

src/main/java/com/alipay/oceanbase/rpc/location/LocationUtil.java

@@ -931,7 +931,6 @@ private static void getTabletLsId(final Connection connection, TableEntry tableE
                     if (rs.wasNull()) {
                         continue;
                     }
-                    logger.warn("[latency monitor] refresh batch location, lsId: {}, tabletId: {}", lsId, tabletId);
                     tabletLsMap.put(tabletId, lsId);
                     ObPartitionLocationInfo partitionLocationInfo = partitionEntry
                         .getPartitionInfo(tabletId);

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

@@ -745,6 +745,7 @@ public void partitionExecute(ObTableSingleOpResult[] results,
         }
 
         long endExecute = System.currentTimeMillis();
+        logger.warn("[latency monitor] finish partitionExecute using: {}", endExecute - startExecute);
 
         if (subLSOpResult == null) {
             String logMessage = String.format(
@@ -832,13 +833,13 @@ private void executeWithRetries(ObTableSingleOpResult[] results,
         currentPartitions.put(entry.getKey(), entry.getValue());
         int errCode = ResultCodes.OB_SUCCESS.errorCode;
         String errMsg = null;
-        long runTimeMaxWait = obTableClient.getRuntimeMaxWait();
+        long runTimeMaxWait = obTableClient.getRuntimeBatchMaxWait();
         long startExecute = System.currentTimeMillis();
         while (true) {
             long costMillis = System.currentTimeMillis() - startExecute;
             if (costMillis > runTimeMaxWait) {
                 errMsg = tableName + " failed to execute operation after retrying " + retryCount
-                        + " times and it has waited" +  costMillis + " ms"
+                        + " times and it has waited " +  costMillis + " ms"
                         + " which exceeds runtime max wait timeout " + runTimeMaxWait
                         + " ms. Last error Msg:" + "[errCode=" + errCode + "] " + errMsg;
                 logger.error(errMsg);
@@ -851,6 +852,7 @@ private void executeWithRetries(ObTableSingleOpResult[] results,
                     partitionExecute(results, currentEntry);
                 } catch (Exception e) {
                     if (shouldRetry(e)) {
+                        long start = System.currentTimeMillis();
                         logger.warn("ls batch meet should retry exception", e);
                         retryCount++;
                         errCode = ((ObTableNeedFetchMetaException) e).getErrorCode();
@@ -859,6 +861,7 @@ private void executeWithRetries(ObTableSingleOpResult[] results,
                             .getValue());
                         currentPartitions = prepareOperations(failedOperations);
                         allPartitionsSuccess = false;
+                        logger.warn("[latency monitor] finish ls batch retry prepare using: {}", System.currentTimeMillis() - start);
                         break;
                     } else {
                         throw e;