zhannngchen commented on code in PR #40340:
URL: https://github.com/apache/doris/pull/40340#discussion_r1759643723
##########
fe/fe-core/src/main/java/org/apache/doris/cloud/transaction/CloudGlobalTransactionMgr.java:
##########
@@ -959,7 +961,19 @@ public boolean commitAndPublishTransaction(DatabaseIf db,
long transactionId,
public boolean commitAndPublishTransaction(DatabaseIf db, List<Table>
tableList, long transactionId,
List<TabletCommitInfo>
tabletCommitInfos, long timeoutMillis,
TxnCommitAttachment
txnCommitAttachment) throws UserException {
+ for (int i = 0; i < tableList.size(); i++) {
+ long tableId = tableList.get(i).getId();
+ LOG.info("start commit txn=" + transactionId + ",table=" +
tableId);
+ }
+ for (Map.Entry<Long, AtomicInteger> entry : countMap.entrySet()) {
+ if (entry.getValue().get() > 5) {
+ LOG.info("now table {} commitAndPublishTransaction queue is
{}", entry.getKey(),
Review Comment:
also print queue length?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
