This is an automated email from the ASF dual-hosted git repository. dataroaring pushed a commit to branch branch-3.0 in repository https://gitbox.apache.org/repos/asf/doris.git
commit 7136a034019deecdb5b4e82ba446f1781acdf89f Author: zhengyu <[email protected]> AuthorDate: Tue May 28 09:31:51 2024 +0800 [fix](statistics) NPE when drop partition during publish (#35475) 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 --- .../main/java/org/apache/doris/transaction/PublishVersionDaemon.java | 5 ++++- 1 file changed, 4 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 c9dd3dd258a..f7a9483c876 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 @@ -48,6 +48,7 @@ import java.util.Collections; import java.util.List; import java.util.Map; import java.util.Map.Entry; +import java.util.Optional; import java.util.Set; import java.util.concurrent.atomic.AtomicBoolean; import java.util.stream.Collectors; @@ -262,7 +263,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) --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
