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 2abbc072b9f697..c3a8bcc450cad7 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 @@ -1757,7 +1757,7 @@ public void finishTransaction(long dbId, long transactionId, Map par public List getUnFinishedPreviousLoad(long endTransactionId, long dbId, List tableIdList) throws UserException { - LOG.info("getUnFinishedPreviousLoad(), endTransactionId:{}, dbId:{}, tableIdList:{}", + LOG.debug("getUnFinishedPreviousLoad(), endTransactionId:{}, dbId:{}, tableIdList:{}", endTransactionId, dbId, tableIdList); if (endTransactionId <= 0) { @@ -1772,10 +1772,10 @@ public List getUnFinishedPreviousLoad(long endTransactionId, l 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()); } @@ -1794,7 +1794,7 @@ public List getUnFinishedPreviousLoad(long endTransactionId, l @Override public boolean isPreviousTransactionsFinished(long endTransactionId, long dbId, List tableIdList) throws AnalysisException { - LOG.info("isPreviousTransactionsFinished(), endTransactionId:{}, dbId:{}, tableIdList:{}", + LOG.debug("isPreviousTransactionsFinished(), endTransactionId:{}, dbId:{}, tableIdList:{}", endTransactionId, dbId, tableIdList); if (endTransactionId <= 0) { @@ -1809,10 +1809,10 @@ public boolean isPreviousTransactionsFinished(long endTransactionId, long dbId, 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()); } @@ -1830,7 +1830,7 @@ public boolean isPreviousTransactionsFinished(long endTransactionId, long dbId, public boolean isPreviousNonTimeoutTxnFinished(long endTransactionId, long dbId, List tableIdList) throws AnalysisException { - LOG.info("isPreviousNonTimeoutTxnFinished(), endTransactionId:{}, dbId:{}, tableIdList:{}", + LOG.debug("isPreviousNonTimeoutTxnFinished(), endTransactionId:{}, dbId:{}, tableIdList:{}", endTransactionId, dbId, tableIdList); if (endTransactionId <= 0) { @@ -1846,10 +1846,10 @@ public boolean isPreviousNonTimeoutTxnFinished(long endTransactionId, long dbId, 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()); }