You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by li...@apache.org on 2023/02/06 02:16:26 UTC

[rocketmq] branch develop updated: [ISSUE #5969] Remvoe duplicate deleteUnusedStats in admin processor (#5973)

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

lizhimin 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 b6e0bf318 [ISSUE #5969] Remvoe duplicate deleteUnusedStats in admin processor (#5973)
b6e0bf318 is described below

commit b6e0bf318080eee8b38f690a56829108f457eb28
Author: zhiliatom <87...@users.noreply.github.com>
AuthorDate: Mon Feb 6 10:16:05 2023 +0800

    [ISSUE #5969] Remvoe duplicate deleteUnusedStats in admin processor (#5973)
---
 .../org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java    | 4 ----
 1 file changed, 4 deletions(-)

diff --git a/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java b/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
index 5df7902dc..78f50c92b 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
@@ -527,10 +527,6 @@ public class AdminBrokerProcessor implements NettyRequestProcessor {
         this.brokerController.getConsumerOffsetManager().cleanOffsetByTopic(requestHeader.getTopic());
         this.brokerController.getPopInflightMessageCounter().clearInFlightMessageNumByTopicName(requestHeader.getTopic());
         this.brokerController.getMessageStore().deleteTopics(Sets.newHashSet(requestHeader.getTopic()));
-        if (this.brokerController.getBrokerConfig().isAutoDeleteUnusedStats()) {
-            this.brokerController.getBrokerStatsManager().onTopicDeleted(requestHeader.getTopic());
-        }
-
         response.setCode(ResponseCode.SUCCESS);
         response.setRemark(null);
         return response;