This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 72385a5f364 [fix](cloud) Change CloudGlobalTransactionMgr some log to
debug level (#57168)
72385a5f364 is described below
commit 72385a5f364b05ee5aff18e36ff185accd1a6b4c
Author: deardeng <[email protected]>
AuthorDate: Wed Oct 22 22:10:21 2025 +0800
[fix](cloud) Change CloudGlobalTransactionMgr some log to debug level
(#57168)
### What problem does this PR solve?
If there are many tables in the db, a lot of logs will be printed here,
consuming a lot of FE log disks
---
.../cloud/transaction/CloudGlobalTransactionMgr.java | 18 +++++++++---------
1 file changed, 9 insertions(+), 9 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/cloud/transaction/CloudGlobalTransactionMgr.java
b/fe/fe-core/src/main/java/org/apache/doris/cloud/transaction/CloudGlobalTransactionMgr.java
index fa3617a96a5..3cb313e02d6 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/cloud/transaction/CloudGlobalTransactionMgr.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/cloud/transaction/CloudGlobalTransactionMgr.java
@@ -1875,7 +1875,7 @@ public class CloudGlobalTransactionMgr implements
GlobalTransactionMgrIface {
public List<TransactionState> getUnFinishedPreviousLoad(long
endTransactionId, long dbId, List<Long> tableIdList)
throws UserException {
- LOG.info("getUnFinishedPreviousLoad(), endTransactionId:{}, dbId:{},
tableIdList:{}",
+ LOG.debug("getUnFinishedPreviousLoad(), endTransactionId:{}, dbId:{},
tableIdList:{}",
endTransactionId, dbId, tableIdList);
if (endTransactionId <= 0) {
@@ -1890,10 +1890,10 @@ public class CloudGlobalTransactionMgr implements
GlobalTransactionMgrIface {
final CheckTxnConflictRequest checkTxnConflictRequest =
builder.build();
CheckTxnConflictResponse checkTxnConflictResponse = null;
try {
- LOG.info("CheckTxnConflictRequest:{}", checkTxnConflictRequest);
+ LOG.debug("CheckTxnConflictRequest:{}", checkTxnConflictRequest);
checkTxnConflictResponse = MetaServiceProxy
.getInstance().checkTxnConflict(checkTxnConflictRequest);
- LOG.info("CheckTxnConflictResponse: {}", checkTxnConflictResponse);
+ LOG.debug("CheckTxnConflictResponse: {}",
checkTxnConflictResponse);
} catch (RpcException e) {
throw new UserException(e.getMessage());
}
@@ -1912,7 +1912,7 @@ public class CloudGlobalTransactionMgr implements
GlobalTransactionMgrIface {
@Override
public boolean isPreviousTransactionsFinished(long endTransactionId, long
dbId, List<Long> tableIdList)
throws AnalysisException {
- LOG.info("isPreviousTransactionsFinished(), endTransactionId:{},
dbId:{}, tableIdList:{}",
+ LOG.debug("isPreviousTransactionsFinished(), endTransactionId:{},
dbId:{}, tableIdList:{}",
endTransactionId, dbId, tableIdList);
if (endTransactionId <= 0) {
@@ -1927,10 +1927,10 @@ public class CloudGlobalTransactionMgr implements
GlobalTransactionMgrIface {
final CheckTxnConflictRequest checkTxnConflictRequest =
builder.build();
CheckTxnConflictResponse checkTxnConflictResponse = null;
try {
- LOG.info("CheckTxnConflictRequest:{}", checkTxnConflictRequest);
+ LOG.debug("CheckTxnConflictRequest:{}", checkTxnConflictRequest);
checkTxnConflictResponse = MetaServiceProxy
.getInstance().checkTxnConflict(checkTxnConflictRequest);
- LOG.info("CheckTxnConflictResponse: {}", checkTxnConflictResponse);
+ LOG.debug("CheckTxnConflictResponse: {}",
checkTxnConflictResponse);
} catch (RpcException e) {
throw new AnalysisException(e.getMessage());
}
@@ -1948,7 +1948,7 @@ public class CloudGlobalTransactionMgr implements
GlobalTransactionMgrIface {
public boolean isPreviousNonTimeoutTxnFinished(long endTransactionId, long
dbId, List<Long> tableIdList)
throws AnalysisException {
- LOG.info("isPreviousNonTimeoutTxnFinished(), endTransactionId:{},
dbId:{}, tableIdList:{}",
+ LOG.debug("isPreviousNonTimeoutTxnFinished(), endTransactionId:{},
dbId:{}, tableIdList:{}",
endTransactionId, dbId, tableIdList);
if (endTransactionId <= 0) {
@@ -1964,10 +1964,10 @@ public class CloudGlobalTransactionMgr implements
GlobalTransactionMgrIface {
final CheckTxnConflictRequest checkTxnConflictRequest =
builder.build();
CheckTxnConflictResponse checkTxnConflictResponse = null;
try {
- LOG.info("CheckTxnConflictRequest:{}", checkTxnConflictRequest);
+ LOG.debug("CheckTxnConflictRequest:{}", checkTxnConflictRequest);
checkTxnConflictResponse = MetaServiceProxy
.getInstance().checkTxnConflict(checkTxnConflictRequest);
- LOG.info("CheckTxnConflictResponse: {}", checkTxnConflictResponse);
+ LOG.debug("CheckTxnConflictResponse: {}",
checkTxnConflictResponse);
} catch (RpcException e) {
throw new AnalysisException(e.getMessage());
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
