Fix stream load with no-2pc mistake write prepare edit log bug

StarRocks · Sep 20, 2024 · 283eb73 · 283eb73
1 parent 51501da
commit 283eb73
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/fe/fe-core/src/main/java/com/starrocks/transaction/DatabaseTransactionMgr.java b/fe/fe-core/src/main/java/com/starrocks/transaction/DatabaseTransactionMgr.java
@@ -363,8 +363,9 @@ public void prepareTransaction(long transactionId, List<TabletCommitInfo> tablet
                 // after state transform
                 transactionState.afterStateTransform(TransactionStatus.PREPARED, txnOperated, callback, null);
             }
-
-            persistTxnStateInTxnLevelLock(transactionState);
+            if (writeEditLog) {
+                persistTxnStateInTxnLevelLock(transactionState);
+            }
 
             LOG.info("transaction:[{}] successfully prepare", transactionState);
         } finally {