Skip to content

Commit

Permalink
edit
Browse files Browse the repository at this point in the history
  • Loading branch information
hust-hhb committed Dec 26, 2024
1 parent 573c3f5 commit 821f0e1
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -354,7 +354,7 @@ public void commitTransaction(long dbId, List<Table> tableList, long transaction
backendToPartitionInfos = getMowLock(mowTableList,
tabletCommitInfos, transactionId, null);
}
commitTransaction(dbId, tableList, transactionId, tabletCommitInfos, txnCommitAttachment, false,
commitTransactionWithoutLock(dbId, tableList, transactionId, tabletCommitInfos, txnCommitAttachment, false,
mowTableList, backendToPartitionInfos);
} catch (Exception e) {
if (!mowTableList.isEmpty()) {
Expand Down Expand Up @@ -481,7 +481,7 @@ private Set<Long> getBaseTabletsFromTables(List<Table> tableList, List<TabletCom
return baseTabletIds;
}

private void commitTransaction(long dbId, List<Table> tableList, long transactionId,
private void commitTransactionWithoutLock(long dbId, List<Table> tableList, long transactionId,
List<TabletCommitInfo> tabletCommitInfos, TxnCommitAttachment txnCommitAttachment, boolean is2PC,
List<OlapTable> mowTableList, Map<Long, List<TCalcDeleteBitmapPartitionInfo>> backendToPartitionInfos)
throws UserException {
Expand Down Expand Up @@ -1226,7 +1226,7 @@ public boolean commitAndPublishTransaction(DatabaseIf db, List<Table> tableList,
public void commitTransaction2PC(Database db, List<Table> tableList, long transactionId, long timeoutMillis)
throws UserException {
List<OlapTable> mowTableList = getMowTableList(tableList, null);
commitTransaction(db.getId(), tableList, transactionId, null, null, true, mowTableList, null);
commitTransactionWithoutLock(db.getId(), tableList, transactionId, null, null, true, mowTableList, null);
}

@Override
Expand Down

0 comments on commit 821f0e1

Please sign in to comment.