From d36ba97eae62f564b15fc31509b346f5f4d3ddea Mon Sep 17 00:00:00 2001 From: zhengyu Date: Thu, 22 Aug 2024 09:57:45 +0800 Subject: [PATCH] [fix](statistics) correct update rows when doing multi-table load (#39548) rows of only one table is updated correctly, need to merge all table commit infos. Signed-off-by: freemandealer --- .../apache/doris/transaction/PublishVersionDaemon.java | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/transaction/PublishVersionDaemon.java b/fe/fe-core/src/main/java/org/apache/doris/transaction/PublishVersionDaemon.java index ac1cbe9154..d27c618c91 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/transaction/PublishVersionDaemon.java +++ b/fe/fe-core/src/main/java/org/apache/doris/transaction/PublishVersionDaemon.java @@ -127,7 +127,14 @@ public class PublishVersionDaemon extends MasterDaemon { partitionCommitInfos.addAll(tableCommitInfo.getIdToPartitionCommitInfo().values()); try { - beIdToBaseTabletIds.putAll(getBaseTabletIdsForEachBe(transactionState, tableCommitInfo)); + Map> map = getBaseTabletIdsForEachBe(transactionState, tableCommitInfo); + map.forEach((beId, newSet) -> { + beIdToBaseTabletIds.computeIfPresent(beId, (id, orgSet) -> { + orgSet.addAll(newSet); + return orgSet; + }); + beIdToBaseTabletIds.putIfAbsent(beId, newSet); + }); } catch (MetaNotFoundException e) { LOG.warn("exception occur when trying to get rollup tablets info", e); }