From 1fd4996ee79477e0c0ad0b7d88ff7af27a45d072 Mon Sep 17 00:00:00 2001 From: JackShi148 Date: Fri, 25 Apr 2025 16:01:29 +0800 Subject: [PATCH] remove redundant log, add debug log --- .../alipay/oceanbase/rpc/ObTableClient.java | 10 ++++-- .../rpc/bolt/transport/ObTableConnection.java | 1 - .../oceanbase/rpc/location/LocationUtil.java | 13 ++------ .../location/model/RouteTableRefresher.java | 4 --- .../rpc/location/model/TableLocations.java | 32 ++++--------------- .../rpc/location/model/TableRoute.java | 4 --- .../query/AbstractQueryStreamResult.java | 3 +- .../alipay/oceanbase/rpc/table/ObTable.java | 8 ++--- .../rpc/table/ObTableClientBatchOpsImpl.java | 2 ++ .../table/ObTableClientLSBatchOpsImpl.java | 7 ++-- 10 files changed, 27 insertions(+), 57 deletions(-) diff --git a/src/main/java/com/alipay/oceanbase/rpc/ObTableClient.java b/src/main/java/com/alipay/oceanbase/rpc/ObTableClient.java index d022d503..c7e58f58 100644 --- a/src/main/java/com/alipay/oceanbase/rpc/ObTableClient.java +++ b/src/main/java/com/alipay/oceanbase/rpc/ObTableClient.java @@ -484,7 +484,8 @@ private T execute(String tableName, TableExecuteCallback callback, ObServ } tableParam = getTableParamWithRoute(tableName, rowKey, route); } - logger.warn("[latency monitor] tableParm obTable ip:port is {}:{}", tableParam.getObTable().getIp(), tableParam.getObTable().getPort()); + logger.debug("tableName: {}, tableParam obTable ip:port is {}:{}", + tableName, tableParam.getObTable().getIp(), tableParam.getObTable().getPort()); T t = callback.execute(tableParam); resetExecuteContinuousFailureCount(tableName); return t; @@ -570,6 +571,8 @@ private T execute(String tableName, TableExecuteCallback callback, ObServ logger.warn(logMessage, ex); if (ex instanceof ObTableTransportException && ((ObTableTransportException) ex).getErrorCode() == TransportCodes.BOLT_TIMEOUT) { + logger.debug("client execute meet transport timeout, obTable ip:port is {}:{}", + tableParam.getObTable().getIp(), tableParam.getObTable().getPort()); syncRefreshMetadata(true); TableEntry entry = tableRoute.getTableEntry(tableName); long partId = tableRoute.getPartId(entry, rowKey); @@ -700,7 +703,8 @@ private T execute(String tableName, OperationExecuteCallback callback, throw new ObTableException("RowKey or scan range is null"); } } - logger.warn("[latency monitor] tableParm obTable ip:port is {}:{}", tableParam.getObTable().getIp(), tableParam.getObTable().getPort()); + logger.debug("tableName: {}, tableParam obTable ip:port is {}:{}", + tableName, tableParam.getObTable().getIp(), tableParam.getObTable().getPort()); T t = callback.execute(tableParam); resetExecuteContinuousFailureCount(tableName); return t; @@ -790,6 +794,8 @@ private T execute(String tableName, OperationExecuteCallback callback, logger.warn(logMessage, ex); if (ex instanceof ObTableTransportException && ((ObTableTransportException) ex).getErrorCode() == TransportCodes.BOLT_TIMEOUT) { + logger.debug("client execute meet transport timeout, obTable ip:port is {}:{}", + tableParam.getObTable().getIp(), tableParam.getObTable().getPort()); syncRefreshMetadata(true); TableEntry entry = tableRoute.getTableEntry(tableName); long partId = tableRoute.getPartId(entry, callback.getRowKey()); diff --git a/src/main/java/com/alipay/oceanbase/rpc/bolt/transport/ObTableConnection.java b/src/main/java/com/alipay/oceanbase/rpc/bolt/transport/ObTableConnection.java index 3b7ea473..a36e1b59 100644 --- a/src/main/java/com/alipay/oceanbase/rpc/bolt/transport/ObTableConnection.java +++ b/src/main/java/com/alipay/oceanbase/rpc/bolt/transport/ObTableConnection.java @@ -232,7 +232,6 @@ public void checkStatus() throws Exception { reconnect("Check connection is null"); } if (connection.getChannel() == null || !connection.getChannel().isActive()) { - LOGGER.warn("[latency monitor] need to reconnect server: {}:{}", obTable.getIp(), obTable.getPort()); reconnect("Check connection failed for address: " + connection.getUrl()); } if (!connection.getChannel().isWritable()) { diff --git a/src/main/java/com/alipay/oceanbase/rpc/location/LocationUtil.java b/src/main/java/com/alipay/oceanbase/rpc/location/LocationUtil.java index 9f9d9b67..e382e408 100644 --- a/src/main/java/com/alipay/oceanbase/rpc/location/LocationUtil.java +++ b/src/main/java/com/alipay/oceanbase/rpc/location/LocationUtil.java @@ -417,10 +417,7 @@ private static TableEntry callTableEntryRefresh(ObServerAddr obServerAddr, Table Connection connection = null; TableEntry entry; try { - long start = System.currentTimeMillis(); connection = getMetaRefreshConnection(url, sysUA); - logger.warn("[latency monitor] time to build JDBC connection: {}", - System.currentTimeMillis() - start); entry = callback.execute(connection); } catch (ObTableNotExistException e) { // avoid to refresh meta for ObTableNotExistException @@ -735,7 +732,6 @@ private static TableEntry getTableEntryFromRemote(final Connection connection, int tenantId = -1; int retryTimes = 0; long sleepTime = 100L; - long start = System.currentTimeMillis(); try { while (true) { try { @@ -854,8 +850,6 @@ private static TableEntry getTableEntryFromRemote(final Connection connection, } } // end while } finally { - logger.warn("[latency monitor] finish get table entry from remote, execute time: {}", - System.currentTimeMillis() - start); try { if (null != rs) { rs.close(); @@ -1006,7 +1000,6 @@ public static TableEntry getTableEntryLocationInBatchFromRemote(final Connection ObTableEntryRefreshException, ObTableSchemaVersionMismatchException { try { - long start = System.currentTimeMillis(); int tenantId = checkTenantExistFromRemote(connection, key); Long[] tablets = null; if (tableEntry.isPartitionTable()) { @@ -1018,12 +1011,10 @@ 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); + logger.debug("refresh batch location, withLsId, {}", withLsId); if (withLsId) { getTabletLsId(connection, tableEntry, tablets, tenantId); } - logger.warn("[latency monitor] finish get tablet locations in batch, execute time: {}", - System.currentTimeMillis() - start); } catch (SQLException e) { // cannot execute sql, maybe some of the observers have been killed RUNTIME.error(LCD.convert("01-00010"), key, tableEntry, e.getMessage()); @@ -1456,7 +1447,7 @@ private static TableEntry getTableEntryFromResultSet(TableEntryKey key, ResultSe } TableLocation tableLocation = new TableLocation(); tableLocation.setReplicaLocations(replicaLocations); - logger.info("refresh meta get new schema_version: {}", schemaVersion); + logger.debug("refresh meta get new schema_version: {}", schemaVersion); if (!replicaLocations.isEmpty()) { entry.setTableId(tableId); entry.setTableLocation(tableLocation); diff --git a/src/main/java/com/alipay/oceanbase/rpc/location/model/RouteTableRefresher.java b/src/main/java/com/alipay/oceanbase/rpc/location/model/RouteTableRefresher.java index 5996d46a..27eef0a0 100644 --- a/src/main/java/com/alipay/oceanbase/rpc/location/model/RouteTableRefresher.java +++ b/src/main/java/com/alipay/oceanbase/rpc/location/model/RouteTableRefresher.java @@ -44,7 +44,6 @@ public RouteTableRefresher(ObTableClient tableClient) { * */ private void doRsListCheck() { try { - logger.info("[latency monitor] background refresher start"); TableRoute tableRoute = tableClient.getTableRoute(); ConfigServerInfo configServer = tableRoute.getConfigServerInfo(); List oldRsList = configServer.getRsList(); @@ -53,7 +52,6 @@ private void doRsListCheck() { tableClient.getRsListAcquireConnectTimeout(), tableClient.getRsListAcquireReadTimeout(), tableClient.getRsListAcquireTryTimes(), tableClient.getRsListAcquireRetryInterval()); - logger.info("[latency monitor] finish loadRsListForConfigServerInfo"); List newRsList = newConfigServer.getRsList(); boolean needRefresh = false; if (oldRsList.size() != newRsList.size()) { @@ -73,7 +71,6 @@ private void doRsListCheck() { } } } - logger.info("[latency monitor] finish needRefresh checking, needRefresh: {}", needRefresh); if (needRefresh) { newConfigServer = LocationUtil.refreshIDC2RegionMapFroConfigServerInfo( newConfigServer, tableClient.getParamURL(), @@ -84,7 +81,6 @@ private void doRsListCheck() { tableRoute.setConfigServerInfo(newConfigServer); tableRoute.refreshRosterByRsList(newRsList); } - logger.info("[latency monitor] finish doRsListCheck"); } catch (Exception e) { logger.warn("RouteTableRefresher::doRsListCheck fail", e); } diff --git a/src/main/java/com/alipay/oceanbase/rpc/location/model/TableLocations.java b/src/main/java/com/alipay/oceanbase/rpc/location/model/TableLocations.java index c7983562..1683c083 100644 --- a/src/main/java/com/alipay/oceanbase/rpc/location/model/TableLocations.java +++ b/src/main/java/com/alipay/oceanbase/rpc/location/model/TableLocations.java @@ -117,7 +117,6 @@ public TableEntry refreshMeta(String tableName, ServerRoster serverRoster, return tableEntry; } } - long start = System.currentTimeMillis(); Lock lock = getMetaRefreshLock(tableName); boolean acquired = false; try { @@ -137,7 +136,6 @@ public TableEntry refreshMeta(String tableName, ServerRoster serverRoster, } tryTimes++; try { - logger.warn("[latency monitor] try to acquire refresh table meta lock, tableName: {}", tableName); if (!acquired) { acquired = lock.tryLock(tableEntryRefreshLockTimeout, TimeUnit.MILLISECONDS); } @@ -145,10 +143,9 @@ public TableEntry refreshMeta(String tableName, ServerRoster serverRoster, String errMsg = "try to lock tableEntry refreshing timeout, tableName:" + tableName + " , timeout:" + tableEntryRefreshLockTimeout + "."; RUNTIME.warn(errMsg); - logger.warn("[latency monitor] fail to acquire refresh table meta lock, tableName: {}", tableName); throw new ObTableTryLockTimeoutException(errMsg); } - logger.warn("[latency monitor] success to acquire refresh table meta lock, tableName: {}", tableName); + logger.debug("success to acquire refresh table meta lock, tableName: {}", tableName); tableEntry = locations.get(tableName); if (tableEntry != null) { long current = System.currentTimeMillis(); @@ -192,7 +189,6 @@ public TableEntry refreshMeta(String tableName, ServerRoster serverRoster, } } // end while } finally { - logger.warn("[latency monitor] unlock refresh table meta lock, tableName: {}, execute time: {}", tableName, System.currentTimeMillis() - start); if (acquired) { lock.unlock(); } @@ -214,7 +210,6 @@ private TableEntry refreshTableEntry(TableEntry tableEntry, String tableName, TableEntryKey tableEntryKey = new TableEntryKey(tableClient.getClusterName(), tableClient.getTenantName(), tableClient.getDatabase(), tableName); try { - long start = System.currentTimeMillis(); // tableEntry will point to a new object, the old tableEntry will be gc by jvm tableEntry = loadTableEntryWithPriority(serverRoster, // tableEntry, // @@ -223,7 +218,6 @@ private TableEntry refreshTableEntry(TableEntry tableEntry, String tableName, tableClient.getTableEntryAcquireSocketTimeout(),// tableClient.getServerAddressPriorityTimeout(), sysUA, !tableClient .getServerCapacity().isSupportDistributedExecute()); - logger.warn("[latency monitor] finish loadTableEntryWithPriority in refresh meta, execute time: {}", System.currentTimeMillis() - start); if (tableEntry.isPartitionTable()) { switch (tableClient.getRunningMode()) { case HBASE: @@ -306,8 +300,6 @@ public TableEntry refreshPartitionLocation(TableEntry tableEntry, String tableNa } Lock lock = locationInfo.refreshLock; boolean acquired = false; - logger.warn("[latency monitor] try to acquire refresh table location lock, tableName: {}", tableName); - long start = System.currentTimeMillis(); try { int tryTimes = 0; long startExecute = System.currentTimeMillis(); @@ -334,7 +326,7 @@ public TableEntry refreshPartitionLocation(TableEntry tableEntry, String tableNa RUNTIME.warn(errMsg); throw new ObTableTryLockTimeoutException(errMsg); } - logger.warn("[latency monitor] success acquire refresh table location lock, tableName: {}", tableName); + logger.debug("success acquire refresh table location lock, tableName: {}", tableName); locationInfo = tableEntry.getPartitionEntry().getPartitionInfo(tabletId); lastRefreshTime = locationInfo.getLastUpdateTime(); currentTime = System.currentTimeMillis(); @@ -345,7 +337,6 @@ public TableEntry refreshPartitionLocation(TableEntry tableEntry, String tableNa tableName, lastRefreshTime, tableEntryRefreshInterval, currentTime); return tableEntry; } - logger.warn("[latency monitor] do refresh table location lock, tableName: {}", tableName); tableEntry = loadTableEntryLocationWithPriority(serverRoster, tableEntryKey, tableEntry, tabletId, tableClient.getTableEntryAcquireConnectTimeout(), tableClient.getTableEntryAcquireSocketTimeout(), @@ -363,12 +354,12 @@ public TableEntry refreshPartitionLocation(TableEntry tableEntry, String tableNa RUNTIME.error( "refresh partition location meet schema_version mismatched exception, tryTimes: {}", tryTimes, e); long schemaVersion = tableEntry.getSchemaVersion(); - logger.warn("[latency monitor] old schema_version is: {}", schemaVersion); + logger.debug( + "schema_version mismatch when refreshing tablet location, 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(); - logger.warn("[latency monitor] interval is: {}", interval); if (interval < 100) { Thread.sleep(100 - interval); } @@ -402,10 +393,6 @@ public TableEntry refreshPartitionLocation(TableEntry tableEntry, String tableNa tableEntryRefreshContinuousFailureCount.set(0); return tableEntry; } finally { - logger - .warn( - "[latency monitor] finish refresh table location lock, tableName: {}, execute time: {}", - tableName, System.currentTimeMillis() - start); if (acquired) { lock.unlock(); } @@ -445,8 +432,6 @@ public TableEntry refreshTabletLocationBatch(TableEntry tableEntry, String table } Lock lock = getLocationBatchRefreshLock(tableName); boolean acquired = false; - logger.warn("[latency monitor] try to acquire refresh tablet locations in batch lock, tableName: {}", tableName); - long start = System.currentTimeMillis(); try { int tryTimes = 0; long startExecute = System.currentTimeMillis(); @@ -468,13 +453,12 @@ public TableEntry refreshTabletLocationBatch(TableEntry tableEntry, String table acquired = lock.tryLock(tableEntryRefreshLockTimeout, TimeUnit.MILLISECONDS); } if (!acquired) { - logger.warn("[latency monitor] fail to acquire refresh tablet locations in batch lock, tableName: {}", tableName); String errMsg = "try to lock locations refreshing in batch timeout " + " ,tableName:" + tableName + " , timeout:" + tableEntryRefreshLockTimeout + "."; RUNTIME.warn(errMsg); throw new ObTableTryLockTimeoutException(errMsg); } - logger.warn("[latency monitor] success to acquire refresh tablet locations in batch lock, tableName: {}", tableName); + logger.debug("success to acquire refresh tablet locations in batch lock, tableName: {}", tableName); lastRefreshTime = tableEntry.getPartitionEntry().getLastRefreshAllTime(); currentTime = System.currentTimeMillis(); if (currentTime - lastRefreshTime < refreshBatchTabletInterval) { @@ -484,7 +468,6 @@ public TableEntry refreshTabletLocationBatch(TableEntry tableEntry, String table tableName, lastRefreshTime, refreshBatchTabletInterval, currentTime); return tableEntry; } - logger.warn("[latency monitor] do refresh tablet locations in batch lock, tableName: {}", tableName); tableEntry = loadTableEntryLocationInBatchWithPriority(serverRoster, tableEntryKey, tableEntry, tableClient.getTableEntryAcquireConnectTimeout(), @@ -503,11 +486,11 @@ public TableEntry refreshTabletLocationBatch(TableEntry tableEntry, String table RUNTIME.error( "refresh location in batch meet schema_version mismatched exception, tryTimes: {}", tryTimes, e); long schemaVersion = tableEntry.getSchemaVersion(); - logger.warn("[latency monitor] old schema_version is: {}", schemaVersion); + logger.debug( + "schema_version mismatch when refreshing tablet locations in batch, 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(); - logger.warn("[latency monitor] interval is: {}", interval); if (interval < 100) { Thread.sleep(100 - interval); } @@ -541,7 +524,6 @@ public TableEntry refreshTabletLocationBatch(TableEntry tableEntry, String table tableEntryRefreshContinuousFailureCount.set(0); return tableEntry; } finally { - logger.warn("[latency monitor] unlock refresh tablet locations in batch lock, tableName: {}, execute time: {}", tableName, System.currentTimeMillis() - start); if (acquired) { lock.unlock(); } diff --git a/src/main/java/com/alipay/oceanbase/rpc/location/model/TableRoute.java b/src/main/java/com/alipay/oceanbase/rpc/location/model/TableRoute.java index 28f69937..c40ed5bd 100644 --- a/src/main/java/com/alipay/oceanbase/rpc/location/model/TableRoute.java +++ b/src/main/java/com/alipay/oceanbase/rpc/location/model/TableRoute.java @@ -390,7 +390,6 @@ public void refreshRosterByRsList(List newRsList) throws Exception allDummyKey, newRsList); throw new ObTableUnexpectedException("all rs servers are not available"); } - logger.warn("[latency monitor] after loadTableEntryRandomly"); // 1. get tenant server address to renew ObTable roster List replicaLocations = tableEntry.getTableLocation() @@ -398,7 +397,6 @@ public void refreshRosterByRsList(List newRsList) throws Exception // update new ob table and get new server address List servers = tableRoster.refreshTablesAndGetNewServers(replicaLocations); serverRoster.reset(servers); - logger.warn("[latency monitor] after refreshTablesAndGetNewServers"); // 2. Get Server LDC info for weak read consistency. success = false; @@ -427,7 +425,6 @@ public void refreshRosterByRsList(List newRsList) throws Exception allDummyKey.getTenantName(), JSON.toJSON(serverRoster)); throw new ObTableUnexpectedException("all tenant servers are not available"); } - logger.warn("[latency monitor] after getServerLdc"); // 3. reset Server LDC location. String regionFromOcp = configServerInfo.getIdc2Region(tableClient.getCurrentIDC()); @@ -751,7 +748,6 @@ private ObTableParam getTableInternal(String tableName, TableEntry tableEntry, l ObServerRoute route) throws Exception { ReplicaLocation replica = null; long tabletId = getTabletIdByPartId(tableEntry, partId); - logger.warn("[latency monitor] tablet id: {}", tabletId); ObPartitionLocationInfo obPartitionLocationInfo = null; obPartitionLocationInfo = getOrRefreshPartitionInfo(tableEntry, tableName, tabletId); if (obPartitionLocationInfo.getPartitionLocation() == null) { diff --git a/src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/query/AbstractQueryStreamResult.java b/src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/query/AbstractQueryStreamResult.java index 1a5f13e8..5da905a9 100644 --- a/src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/query/AbstractQueryStreamResult.java +++ b/src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/query/AbstractQueryStreamResult.java @@ -288,6 +288,8 @@ protected ObPayload commonExecute(ObTableClient client, Logger logger, } else { if (e instanceof ObTableTransportException && ((ObTableTransportException) e).getErrorCode() == TransportCodes.BOLT_TIMEOUT) { + logger.debug("query meet transport timeout, obTable ip:port is {}:{}", + subObTable.getIp(), subObTable.getPort()); client.syncRefreshMetadata(true); long tabletId = partIdWithIndex.getRight().getTabletId(); client.refreshTableLocationByTabletId(indexTableName, tabletId); @@ -536,7 +538,6 @@ protected abstract Map> refreshPartition(ObTabl String tableName) throws Exception; - private void resetCachedResult() { cacheRows.clear(); cacheProperties.clear(); diff --git a/src/main/java/com/alipay/oceanbase/rpc/table/ObTable.java b/src/main/java/com/alipay/oceanbase/rpc/table/ObTable.java index 751ca17e..bcf306f3 100644 --- a/src/main/java/com/alipay/oceanbase/rpc/table/ObTable.java +++ b/src/main/java/com/alipay/oceanbase/rpc/table/ObTable.java @@ -190,13 +190,13 @@ public boolean isEnableRerouting(){ // flag this obTable is valid and available public void setValid() { - log.warn("[latency monitor] set ip:port {}:{} as valid", ip, port); + log.debug("set ip:port {}:{} as valid", ip, port); valid.compareAndSet(false, true); } // flag this obTable is invalid and unavailable public void setDirty() { - log.warn("[latency monitor] set ip:port {}:{} as dirty", ip, port); + log.debug("set ip:port {}:{} as dirty", ip, port); valid.compareAndSet(true, false); } @@ -414,7 +414,7 @@ public ObPayload execute(final ObPayload request) throws RemotingException, InterruptedException { if (!isValid()) { - log.warn("[latency monitor] The server is not available, server address: " + ip + ":" + port); + log.debug("The server is not available, server address: " + ip + ":" + port); throw new ObTableServerConnectException("The server is not available, server address: " + ip + ":" + port); } ObTableConnection connection = null; @@ -479,7 +479,7 @@ public ObPayload executeWithConnection(final ObPayload request, throws RemotingException, InterruptedException { if (!isValid()) { - log.warn("[latency monitor] The server is not available, server address: " + ip + ":" + port); + log.debug("The server is not available, server address: " + ip + ":" + port); throw new ObTableServerConnectException("The server is not available, server address: " + ip + ":" + port); } ObTableConnection connection; diff --git a/src/main/java/com/alipay/oceanbase/rpc/table/ObTableClientBatchOpsImpl.java b/src/main/java/com/alipay/oceanbase/rpc/table/ObTableClientBatchOpsImpl.java index 468d018d..96906ef2 100644 --- a/src/main/java/com/alipay/oceanbase/rpc/table/ObTableClientBatchOpsImpl.java +++ b/src/main/java/com/alipay/oceanbase/rpc/table/ObTableClientBatchOpsImpl.java @@ -457,6 +457,8 @@ public void partitionExecute(ObTableOperationResult[] results, } else { if (ex instanceof ObTableTransportException && ((ObTableTransportException) ex).getErrorCode() == TransportCodes.BOLT_TIMEOUT) { + logger.debug("normal batch meet transport timeout, obTable ip:port is {}:{}", + subObTable.getIp(), subObTable.getPort()); obTableClient.syncRefreshMetadata(true); obTableClient.refreshTableLocationByTabletId(tableName, partId); subObTable.setDirty(); diff --git a/src/main/java/com/alipay/oceanbase/rpc/table/ObTableClientLSBatchOpsImpl.java b/src/main/java/com/alipay/oceanbase/rpc/table/ObTableClientLSBatchOpsImpl.java index 355632c7..53ac97eb 100644 --- a/src/main/java/com/alipay/oceanbase/rpc/table/ObTableClientLSBatchOpsImpl.java +++ b/src/main/java/com/alipay/oceanbase/rpc/table/ObTableClientLSBatchOpsImpl.java @@ -633,7 +633,6 @@ public void partitionExecute(ObTableSingleOpResult[] results, } } } - logger.warn("[latency monitor] ls_id: {}, tryTimes: {}, ip:port is: {}:{}", lsId, tryTimes, subObTable.getIp(), subObTable.getPort()); ObPayload result = subObTable.execute(tableLsOpRequest); if (result != null && result.getPcode() == Pcodes.OB_TABLE_API_MOVE) { ObTableApiMove moveResponse = (ObTableApiMove) result; @@ -729,6 +728,8 @@ public void partitionExecute(ObTableSingleOpResult[] results, } else { if (ex instanceof ObTableTransportException && ((ObTableTransportException) ex).getErrorCode() == TransportCodes.BOLT_TIMEOUT) { + logger.debug("ls batch meet transport timeout, obTable ip:port is {}:{}", + subObTable.getIp(), subObTable.getPort()); obTableClient.syncRefreshMetadata(true); obTableClient.refreshTabletLocationBatch(realTableName); subObTable.setDirty(); @@ -745,7 +746,6 @@ 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( @@ -852,8 +852,6 @@ 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(); errMsg = e.getMessage(); @@ -861,7 +859,6 @@ 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;