This is an automated email from the ASF dual-hosted git repository.

dataroaring pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git


The following commit(s) were added to refs/heads/branch-2.0 by this push:
     new 7456ed20327 [fix](transaction) fix profile null exception cause txn 
stuck (#25575)
7456ed20327 is described below

commit 7456ed2032795396837c4bad871e163c2f98ae6e
Author: yujun <[email protected]>
AuthorDate: Wed Oct 18 22:25:00 2023 +0800

    [fix](transaction) fix profile null exception cause txn stuck (#25575)
---
 .../org/apache/doris/transaction/DatabaseTransactionMgr.java   | 10 +++++++---
 1 file changed, 7 insertions(+), 3 deletions(-)

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 7974cb6a89a..7677c1684f6 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
@@ -698,7 +698,11 @@ public class DatabaseTransactionMgr {
         } finally {
             writeUnlock();
             // after state transform
-            transactionState.afterStateTransform(TransactionStatus.COMMITTED, 
txnOperated);
+            try {
+                
transactionState.afterStateTransform(TransactionStatus.COMMITTED, txnOperated);
+            } catch (Throwable e) {
+                LOG.warn("afterStateTransform txn {} failed. exception: ", 
transactionState, e);
+            }
         }
 
         // update nextVersion because of the failure of persistent transaction 
resulting in error version
@@ -1063,8 +1067,8 @@ public class DatabaseTransactionMgr {
                 writeUnlock();
                 try {
                     
transactionState.afterStateTransform(TransactionStatus.VISIBLE, txnOperated);
-                } catch (UserException e) {
-                    LOG.warn("afterStateTransform txn {} failed. msg: {}", 
transactionId, e.getMessage());
+                } catch (Throwable e) {
+                    LOG.warn("afterStateTransform txn {} failed. exception: ", 
transactionState, e);
                 }
             }
             updateCatalogAfterVisible(transactionState, db);


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to