Skip to content

Commit

Permalink
edit
Browse files Browse the repository at this point in the history
  • Loading branch information
hust-hhb committed Dec 24, 2024
1 parent d8e6dcb commit 573c3f5
Showing 1 changed file with 5 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -358,8 +358,8 @@ public void commitTransaction(long dbId, List<Table> 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;
Expand Down Expand Up @@ -827,6 +827,7 @@ private Map<Long, List<TCalcDeleteBitmapPartitionInfo>> getMowLock(List<OlapTabl
backendToPartitionTablets, partitionVersions, baseCompactionCnts, cumulativeCompactionCnts,
cumulativePoints, partitionToSubTxnIds);
}

private void getDeleteBitmapUpdateLock(Map<Long, Set<Long>> tableToParttions, long transactionId,
Map<Long, List<Long>> tableToTabletList, Map<Long, TabletMeta> tabletToTabletMeta,
Map<Long, Long> baseCompactionCnts, Map<Long, Long> cumulativeCompactionCnts,
Expand Down Expand Up @@ -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;
Expand Down

0 comments on commit 573c3f5

Please sign in to comment.