Skip to content

Commit 7742b7c

Browse files
woaishixiaoxiaoshixiaoxiao
andauthored
[ISSUE #10157] Fix tiered metadata leak after topic delete (#10158)
Co-authored-by: shixiaoxiao <shixiaoxiao@bytedance.com>
1 parent 70834e3 commit 7742b7c

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

tieredstore/src/main/java/org/apache/rocketmq/tieredstore/metadata/DefaultMetadataStore.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -152,6 +152,7 @@ public void updateTopic(TopicMetadata topicMetadata) {
152152
@Override
153153
public void deleteTopic(String topic) {
154154
topicMetadataTable.remove(topic);
155+
queueMetadataTable.remove(topic);
155156
persist();
156157
}
157158

0 commit comments

Comments
 (0)