This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 02fd95a08d1 [fix](statistics) NPE when drop partition during publish
(#35475)
02fd95a08d1 is described below
commit 02fd95a08d1bbc0fa3b91038ea95e8bf8b6718b5
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]
