This is an automated email from the ASF dual-hosted git repository. morningman pushed a commit to branch branch-1.2-lts in repository https://gitbox.apache.org/repos/asf/doris.git
commit a05299070cefa324509242818d34f1fc911fa8cf Author: caiconghui <[email protected]> AuthorDate: Fri Mar 3 19:06:39 2023 +0800 [enhancement](transaction) Reduce hold writeLock time for DatabaseTransactionMgr to improve stability of stream load (#17380) Clear transaction state log occupies too much time, so we change clear transaction log level from info to debug Co-authored-by: caiconghui1 <[email protected]> --- .../java/org/apache/doris/transaction/DatabaseTransactionMgr.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/transaction/DatabaseTransactionMgr.java b/fe/fe-core/src/main/java/org/apache/doris/transaction/DatabaseTransactionMgr.java index dec2a4298f..8a24e4361d 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/transaction/DatabaseTransactionMgr.java +++ b/fe/fe-core/src/main/java/org/apache/doris/transaction/DatabaseTransactionMgr.java @@ -1385,7 +1385,9 @@ public class DatabaseTransactionMgr { dbExpiredTxnIds.put(dbId, expiredTxnIds); BatchRemoveTransactionsOperation op = new BatchRemoveTransactionsOperation(dbExpiredTxnIds); editLog.logBatchRemoveTransactions(op); - LOG.info("Remove {} expired transactions", MAX_REMOVE_TXN_PER_ROUND - leftNum); + if (LOG.isDebugEnabled()) { + LOG.debug("Remove {} expired transactions", MAX_REMOVE_TXN_PER_ROUND - leftNum); + } } } finally { writeUnlock(); @@ -1418,7 +1420,9 @@ public class DatabaseTransactionMgr { if (txnIds.isEmpty()) { labelToTxnIds.remove(transactionState.getLabel()); } - LOG.info("transaction [" + txnId + "] is expired, remove it from transaction manager"); + if (LOG.isDebugEnabled()) { + LOG.debug("transaction [" + txnId + "] is expired, remove it from transaction manager"); + } } else { // should not happen, add a warn log to observer LOG.warn("transaction state is not found when clear transaction: " + txnId); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
