(rocketmq) branch develop updated: [ISSUE #8049] fix tiered store delete empty topic NPE (#8050)

[yuzhou]

This is an automated email from the ASF dual-hosted git repository.

yuzhou pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new ad02756078 [ISSUE #8049] fix tiered store delete empty topic NPE 
(#8050)
ad02756078 is described below

commit ad027560780c2af801e4bcb447d85bf0df62071a
Author: bxfjb <48467309+bx...@users.noreply.github.com>
AuthorDate: Wed May 8 15:39:49 2024 +0800

    [ISSUE #8049] fix tiered store delete empty topic NPE (#8050)
    
    Co-authored-by: zhaoyuhan <zhaoyu...@xiaomi.com>
---
 .../apache/rocketmq/tieredstore/metadata/DefaultMetadataStore.java   | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git 
a/tieredstore/src/main/java/org/apache/rocketmq/tieredstore/metadata/DefaultMetadataStore.java
 
b/tieredstore/src/main/java/org/apache/rocketmq/tieredstore/metadata/DefaultMetadataStore.java
index 630276a97f..09500bf6da 100644
--- 
a/tieredstore/src/main/java/org/apache/rocketmq/tieredstore/metadata/DefaultMetadataStore.java
+++ 
b/tieredstore/src/main/java/org/apache/rocketmq/tieredstore/metadata/DefaultMetadataStore.java
@@ -164,7 +164,10 @@ public class DefaultMetadataStore extends ConfigManager 
implements MetadataStore
 
     @Override
     public void iterateQueue(String topic, Consumer<QueueMetadata> callback) {
-        queueMetadataTable.get(topic).values().forEach(callback);
+        ConcurrentMap<Integer, QueueMetadata> metadataConcurrentMap = 
queueMetadataTable.get(topic);
+        if (metadataConcurrentMap != null) {
+            metadataConcurrentMap.values().forEach(callback);
+        }
     }
 
     @Override