This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new 37d56318a51 [fix](mtmv)fix compile error (#35745)
37d56318a51 is described below
commit 37d56318a51d424188139afdd757dd76460ee2f2
Author: zhangdong <[email protected]>
AuthorDate: Fri May 31 22:02:34 2024 +0800
[fix](mtmv)fix compile error (#35745)
---
.../java/org/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 0462a1ec1ab..43e2ca038bc 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 @@ 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);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
