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

…ug (#51039) (cherry picked from commit 7fd1582)
StarRocks · Sep 20, 2024 · 67943a3 · 67943a3
1 parent 203310f
commit 67943a3
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
@@ -362,8 +362,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 {