fix fail test

apache · Jan 20, 2025 · 07e720b · 07e720b
1 parent ca49bf6
commit 07e720b
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 5 deletions.
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java b/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
@@ -2577,4 +2577,6 @@ public ColdDataCgCtrService getColdDataCgCtrService() {
     public void setColdDataCgCtrService(ColdDataCgCtrService coldDataCgCtrService) {
         this.coldDataCgCtrService = coldDataCgCtrService;
     }
+
+
 }
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
@@ -2674,9 +2674,8 @@ private RemotingCommand fetchAllConsumeStatsInBroker(ChannelHandlerContext ctx,
                         group,
                         topic,
                         i);
-                    if (consumerOffset < 0) {
+                    if (consumerOffset < 0)
                         consumerOffset = 0;
-                    }
 
                     offsetWrapper.setBrokerOffset(brokerOffset);
                     offsetWrapper.setConsumerOffset(consumerOffset);

diff --git a/store/src/main/java/org/apache/rocketmq/store/timer/rocksdb/TimerMessageRocksDBStore.java b/store/src/main/java/org/apache/rocketmq/store/timer/rocksdb/TimerMessageRocksDBStore.java
@@ -184,9 +184,7 @@ public void shutdown() {
     }
 
     public void createTimer(byte[] columnFamily) {
-        for (int i = 0; i < storeConfig.getTimerGetMessageThreadNum(); i++) {
-            this.timerGetMessageServices.add(new TimerGetMessageService(columnFamily));
-        }
+        this.timerGetMessageServices.add(new TimerGetMessageService(columnFamily));
         this.timerWarmServices.add(new TimerWarmService(columnFamily));
     }
     // ----------------------------------------------------------------------------------------------------------------
-Original file line number
+Diff line change
@@ Expand Up / @@ -2577,4 +2577,6 @@ public ColdDataCgCtrService getColdDataCgCtrService() { @@
         public void setColdDataCgCtrService(ColdDataCgCtrService coldDataCgCtrService) {
             this.coldDataCgCtrService = coldDataCgCtrService;
         }
     }