add ls_id refreshing log; refreshMeta retry uses tableEntryRefreshTryTimes

Author: JackShi148

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

@@ -931,6 +931,7 @@ 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);
@@ -1018,6 +1019,7 @@ public static TableEntry getTableEntryLocationInBatchFromRemote(final Connection
             // only if the server has no distribution capacity and this table is partitioned table,
             // the process of fetching lsId need to be separated with the process of fetch tablets location
             // because __all_virtual_tablet_to_ls makes severe impact on performance
+            logger.warn("[latency monitor] refresh batch location, withLsId, {}", withLsId);
             if (withLsId) {
                 getTabletLsId(connection, tableEntry, tablets, tenantId);
             }

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

@@ -140,9 +140,7 @@ public TableEntry refreshMeta(String tableName, ServerRoster serverRoster,
                     return tableEntry;
                 }
             }
-            int serverSize = serverRoster.getMembers().size();
-            int refreshTryTimes = Math.min(tableEntryRefreshTryTimes, serverSize);
-            for (int i = 0; i < refreshTryTimes; ++i) {
+            for (int i = 0; i < tableEntryRefreshTryTimes; ++i) {
                 try {
                     return refreshTableEntry(tableEntry, tableName, serverRoster, sysUA);
                 } catch (ObTableNotExistException e) {
@@ -157,15 +155,11 @@ public TableEntry refreshMeta(String tableName, ServerRoster serverRoster,
                         tableClient.syncRefreshMetadata(false);
                         tableEntryRefreshContinuousFailureCount.set(0);
                         serverRoster = tableClient.getTableRoute().getServerRoster();
-                        refreshTryTimes = Math.min(tableEntryRefreshTryTimes, serverRoster
-                            .getMembers().size());
                     } else if (e.isConnectInactive()) {
                         // getMetaRefreshConnection failed, maybe the server is down, so we need to refresh metadata directly
                         tableClient.syncRefreshMetadata(true);
                         tableEntryRefreshContinuousFailureCount.set(0);
                         serverRoster = tableClient.getTableRoute().getServerRoster();
-                        refreshTryTimes = Math.min(tableEntryRefreshTryTimes, serverRoster
-                            .getMembers().size());
                     }
                 } catch (Throwable t) {
                     RUNTIME.error("refresh table meta meet exception", t);
@@ -175,7 +169,7 @@ public TableEntry refreshMeta(String tableName, ServerRoster serverRoster,
             // maybe the retry time is too small, need to instantly refresh roster
             logger.info(
                 "refresh table entry has tried {}-times failure and will sync refresh metadata",
-                refreshTryTimes);
+                    tableEntryRefreshTryTimes);
             tableClient.syncRefreshMetadata(false);
             tableEntryRefreshContinuousFailureCount.set(0);
             serverRoster = tableClient.getTableRoute().getServerRoster();