opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-19 02:23:24 +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
2024-05-08 15:39:49 +08:00
committed by GitHub
co-authored by zhaoyuhan
parent 5dae822053
commit ad02756078
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