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);