[BugFix] Fix stream load with no-2pc mistake write prepare edit log b…

…ug (#51039)
StarRocks · Sep 20, 2024 · 7fd1582 · 7fd1582
1 parent 37db37f
commit 7fd1582
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 {