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

[fix](statistics) correct update rows when doing multi-table load (#39548)

Browse Source 
rows of only one table is updated correctly, need to merge all table
commit infos.
Signed-off-by: freemandealer <freeman.zhang1992@gmail.com>
This commit is contained in:
zhengyu
2024-08-22 09:57:45 +08:00
committed by GitHub
parent ed9794a0fe
commit d36ba97eae
1 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
fe/fe-core/src/main/java/org/apache/doris/transaction/PublishVersionDaemon.java
View File

@ -127,7 +127,14 @@ public class PublishVersionDaemon extends MasterDaemon {
partitionCommitInfos.addAll(tableCommitInfo.getIdToPartitionCommitInfo().values());
try {
beIdToBaseTabletIds.putAll(getBaseTabletIdsForEachBe(transactionState, tableCommitInfo));
Map<Long, Set<Long>> 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);
}