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

[fix](statistics) NPE when drop partition during publish (pick #35475) (#35977)

Browse Source 
skip null partition when get base tablets for each be (for further usage
in dedup updated row count in MV) This may cause publish fail

cherry pick master #35475
This commit is contained in:
zhengyu
2024-06-06 16:47:30 +08:00
committed by GitHub
parent 85328d4f79
commit fedb7e15a0
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -46,6 +46,7 @@ import java.util.Collection;
import java.util.Collections;
import java.util.List;
import java.util.Map;
import java.util.Optional;
import java.util.Set;
import java.util.stream.Collectors;
import java.util.stream.Stream;
@ -219,7 +220,9 @@ public class PublishVersionDaemon extends MasterDaemon {
.getIdToPartitionCommitInfo()
.values().stream()
.map(PartitionCommitInfo::getPartitionId)
.map(table::getPartition)
.map(partitionId -> Optional.ofNullable(table.getPartition(partitionId)))
.filter(Optional::isPresent)
.map(Optional::get)
.map(Partition::getBaseIndex)
.map(MaterializedIndex::getTablets)
.flatMap(Collection::stream)