opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-19 10:54:54 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ISSUE #8049] fix tiered store delete empty topic NPE (#8050)

Browse Source 
Co-authored-by: zhaoyuhan <zhaoyuhan@xiaomi.com>
This commit is contained in:
bxfjb
2025-07-19 18:17:46 +08:00
committed by RongtongJin
co-authored by zhaoyuhan
parent f0f96923bf
commit fc6752f395
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/metadata/DefaultMetadataStore.java
+4 -1
View File
@@ -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