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 630276a97f6..09500bf6da8 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 QueueMetadata getQueue(MessageQueue mq) {
 
     @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