refresh tableEntry object when refreshing tablet location meeting schema_version mismatched

Author: JackShi148

src/main/java/com/alipay/oceanbase/rpc/location/model/TableLocations.java

@@ -334,11 +334,14 @@ public TableEntry refreshPartitionLocation(TableEntry tableEntry, String tableNa
                         throw e;
                     }
                     long schemaVersion = tableEntry.getSchemaVersion();
+                    logger.warn("[latency monitor] old schema_version is: {}", schemaVersion);
+                    tableEntry = locations.get(tableName);
                     // sleep over waiting interval of refreshing meta to refresh meta
                     long interval = System.currentTimeMillis()
                                     - tableEntry.getRefreshMetaTimeMills();
-                    if (interval > 300) {
-                        Thread.sleep(interval - 300);
+                    logger.warn("[latency monitor] interval is: {}", interval);
+                    if (interval < 300) {
+                        Thread.sleep(300 - interval);
                     }
                     tableEntry = locations.get(tableName);
                     // if schema_version has been updated, directly retry
@@ -461,11 +464,14 @@ public TableEntry refreshTabletLocationBatch(TableEntry tableEntry, String table
                         throw e;
                     }
                     long schemaVersion = tableEntry.getSchemaVersion();
+                    logger.warn("[latency monitor] old schema_version is: {}", schemaVersion);
+                    tableEntry = locations.get(tableName);
                     // sleep over waiting interval of refreshing meta to refresh meta
                     long interval = System.currentTimeMillis()
                                     - tableEntry.getRefreshMetaTimeMills();
-                    if (interval > 300) {
-                        Thread.sleep(interval - 300);
+                    logger.warn("[latency monitor] interval is: {}", interval);
+                    if (interval < 300) {
+                        Thread.sleep(300 - interval);
                     }
                     tableEntry = locations.get(tableName);
                     // if schema_version has been updated, directly retry

src/main/java/com/alipay/oceanbase/rpc/location/model/TableRoute.java

@@ -656,7 +656,6 @@ public ObTableParam getTableParam(String tableName, Row rowkey) throws Exception
 
     public ObTableParam getTableParamWithRoute(String tableName, Row rowkey, ObServerRoute route)
                                                                                                  throws Exception {
-        logger.info("[latency monitor] start to execute getTableParamWithRoute");
         TableEntry tableEntry = getTableEntry(tableName);
         if (tableEntry == null) {
             logger.error("tableEntry is null, tableName: {}", tableName);
@@ -815,7 +814,6 @@ private ObTableParam getTableInternal(String tableName, TableEntry tableEntry, l
             tableEntry = refreshPartitionLocation(tableName, tabletId, tableEntry);
             obPartitionLocationInfo = getOrRefreshPartitionInfo(tableEntry, tableName, tabletId);
             replica = getPartitionLocation(obPartitionLocationInfo, route);
-            logger.warn("[latency monitor] new replica location, {}:{}", replica.getAddr().getIp(), replica.getAddr().getSvrPort());
 
             if (replica == null) {
                 RUNTIME.error("Cannot get replica by tabletId: " + tabletId);

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

@@ -480,7 +480,6 @@ private LsOperationsMap prepareByFirstOperation(LsOperationsMap lsOperationsMap,
 
     private LsOperationsMap prepareByEachOperation(LsOperationsMap lsOperationsMap,
                          BatchIdxOperationPairList operationsWithIndex) throws Exception {
-        logger.info("[latency monitor] start to execute prepareByEachOperation");
         for (int i = 0; i < operationsWithIndex.size(); i++) {
             ObPair<Integer, ObTableSingleOp> operation = operationsWithIndex.get(i);
             Row rowKey = calculateRowKey(operation);
@@ -731,7 +730,6 @@ public void partitionExecute(ObTableSingleOpResult[] results,
                     } else {
                         if (ex instanceof ObTableTransportException &&
                                 ((ObTableTransportException) ex).getErrorCode() == TransportCodes.BOLT_TIMEOUT) {
-                            logger.warn("[latency monitor] meet BOLT_TIMEOUT, need to syncRefreshMetadata, tryTimes: {}", tryTimes);
                             obTableClient.syncRefreshMetadata(true);
                         }
                         obTableClient.calculateContinuousFailure(realTableName, ex.getMessage());