set refresh interval to 100ms from 300ms to ensure refreshing correct ls_id when ls batch retry

Author: JackShi148

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

@@ -96,7 +96,7 @@ public TableEntry refreshMeta(String tableName, ServerRoster serverRoster,
         int tableEntryRefreshContinuousFailureCeiling = tableClient
             .getTableEntryRefreshContinuousFailureCeiling();
         long tableEntryRefreshLockTimeout = tableClient.getTableEntryRefreshLockTimeout();
-        long refreshMetaInterval = 300L;
+        long refreshMetaInterval = 100L;
 
         TableEntry tableEntry = locations.get(tableName);
         // avoid bad contention in high concurrent situation
@@ -275,7 +275,7 @@ public TableEntry refreshPartitionLocation(TableEntry tableEntry, String tableNa
         int tableEntryRefreshTryTimes = tableClient.getTableEntryRefreshTryTimes();
         long tableEntryRefreshLockTimeout = tableClient.getTableEntryRefreshLockTimeout();
         long lastRefreshTime = locationInfo.getLastUpdateTime();
-        long tableEntryRefreshInterval = 300L;
+        long tableEntryRefreshInterval = 100L;
         long currentTime = System.currentTimeMillis();
         // do not refresh tablet location if refreshed within 300 milliseconds
         if (currentTime - lastRefreshTime < tableEntryRefreshInterval) {
@@ -332,8 +332,8 @@ public TableEntry refreshPartitionLocation(TableEntry tableEntry, String tableNa
                     long interval = System.currentTimeMillis()
                                     - tableEntry.getRefreshMetaTimeMills();
                     logger.warn("[latency monitor] interval is: {}", interval);
-                    if (interval < 300) {
-                        Thread.sleep(300 - interval);
+                    if (interval < 100) {
+                        Thread.sleep(100 - interval);
                     }
                     tableEntry = locations.get(tableName);
                     // if schema_version has been updated, directly retry
@@ -397,7 +397,7 @@ public TableEntry refreshTabletLocationBatch(TableEntry tableEntry, String table
         int tableEntryRefreshTryTimes = tableClient.getTableEntryRefreshTryTimes();
         long tableEntryRefreshLockTimeout = tableClient.getTableEntryRefreshLockTimeout();
         long lastRefreshTime = tableEntry.getPartitionEntry().getLastRefreshAllTime();
-        long tableEntryRefreshInterval = 300L;
+        long tableEntryRefreshInterval = 100L;
         long currentTime = System.currentTimeMillis();
         // do not refresh tablet location if refreshed within 300 milliseconds
         if (currentTime - lastRefreshTime < tableEntryRefreshInterval) {
@@ -456,8 +456,8 @@ public TableEntry refreshTabletLocationBatch(TableEntry tableEntry, String table
                     long interval = System.currentTimeMillis()
                                     - tableEntry.getRefreshMetaTimeMills();
                     logger.warn("[latency monitor] interval is: {}", interval);
-                    if (interval < 300) {
-                        Thread.sleep(300 - interval);
+                    if (interval < 100) {
+                        Thread.sleep(100 - interval);
                     }
                     tableEntry = locations.get(tableName);
                     // if schema_version has been updated, directly retry

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

@@ -833,6 +833,9 @@ private void executeWithRetries(ObTableSingleOpResult[] results,
         int errCode = ResultCodes.OB_SUCCESS.errorCode;
         String errMsg = null;
         int maxRetryTimes = obTableClient.getRuntimeRetryTimes();
+        // cannot use runTimeWait to retry to timeout
+        // because in huge-partitioned table situation, if refresh all tablets' locations
+        // it's hard to complete refreshing within time limit
         while (retryCount < maxRetryTimes && !success) {
             boolean allPartitionsSuccess = true;