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 e7b5569f1cd414..3b4a4e0b740bd5 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 @@ -358,8 +358,8 @@ public void commitTransaction(long dbId, List tableList, long transaction mowTableList, backendToPartitionInfos); } catch (Exception e) { if (!mowTableList.isEmpty()) { - LOG.warn("commit txn {} failed, release delete bitmap lock, catch exception {}", transactionId - , e.getMessage()); + LOG.warn("commit txn {} failed, release delete bitmap lock, catch exception {}", transactionId, + e.getMessage()); removeDeleteBitmapUpdateLock(mowTableList, transactionId); } throw e; @@ -827,6 +827,7 @@ private Map> getMowLock(List> tableToParttions, long transactionId, Map> tableToTabletList, Map tabletToTabletMeta, Map baseCompactionCnts, Map cumulativeCompactionCnts, @@ -1127,8 +1128,8 @@ public boolean commitAndPublishTransaction(DatabaseIf db, long transactionId, backendToPartitionInfos); } catch (Exception e) { if (!mowTableList.isEmpty()) { - LOG.warn("commit txn {} failed, release delete bitmap lock, catch exception {}", transactionId - , e.getMessage()); + LOG.warn("commit txn {} failed, release delete bitmap lock, catch exception {}", transactionId, + e.getMessage()); removeDeleteBitmapUpdateLock(mowTableList, transactionId); } throw e;