database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[fix](mtmv)fix compile error (#35745)

Browse Source
This commit is contained in:
zhangdong
2024-05-31 22:02:34 +08:00
committed by GitHub
parent 032a7a1365
commit 37d56318a5
1 changed files with 1 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
fe/fe-core/src/main/java/org/apache/doris/transaction/DatabaseTransactionMgr.java
View File

@ -1088,12 +1088,7 @@ public class DatabaseTransactionMgr {
}
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);