From 95f437c5065c3a2a307c9ccda9889bc3bf11a649 Mon Sep 17 00:00:00 2001 From: TsukiokaKogane Date: Thu, 20 Oct 2022 23:23:36 +0800 Subject: [PATCH] [fix] Fix potential unhandled exception cause data inconsistency (#11029) Co-authored-by: TsukiokaKogane --- .../apache/doris/transaction/DatabaseTransactionMgr.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/transaction/DatabaseTransactionMgr.java b/fe/fe-core/src/main/java/org/apache/doris/transaction/DatabaseTransactionMgr.java index 210684fea9..843df334ee 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/transaction/DatabaseTransactionMgr.java +++ b/fe/fe-core/src/main/java/org/apache/doris/transaction/DatabaseTransactionMgr.java @@ -934,7 +934,11 @@ public class DatabaseTransactionMgr { LOG.debug("after set transaction {} to visible", transactionState); } finally { writeUnlock(); - transactionState.afterStateTransform(TransactionStatus.VISIBLE, txnOperated); + try { + transactionState.afterStateTransform(TransactionStatus.VISIBLE, txnOperated); + } catch (UserException e) { + LOG.warn("afterStateTransform txn {} failed. msg: {}", transactionId, e.getMessage()); + } } updateCatalogAfterVisible(transactionState, db); } finally {