From f7d934d78b71665fc31082c907ca9caa674bf998 Mon Sep 17 00:00:00 2001
From: zhangdong <493738387@qq.com>
Date: Fri, 31 May 2024 21:51:28 +0800
Subject: [PATCH] 1

---
 .../apache/doris/transaction/DatabaseTransactionMgr.java   | 7 +------
 1 file changed, 1 insertion(+), 6 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 0462a1ec1abd14..43e2ca038bcf3f 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
@@ -1088,12 +1088,7 @@ private void setTableVersion(TransactionState transactionState, Database db) {
     }
 
     private void produceEvent(TransactionState transactionState, Database db) {
-        Collection<TableCommitInfo> tableCommitInfos;
-        if (!transactionState.getSubTxnIdToTableCommitInfo().isEmpty()) {
-            tableCommitInfos = transactionState.getSubTxnTableCommitInfos();
-        } else {
-            tableCommitInfos = transactionState.getIdToTableCommitInfos().values();
-        }
+        Collection<TableCommitInfo> tableCommitInfos = transactionState.getIdToTableCommitInfos().values();
         for (TableCommitInfo tableCommitInfo : tableCommitInfos) {
             long tableId = tableCommitInfo.getTableId();
             OlapTable table = (OlapTable) db.getTableNullable(tableId);