This is an automated email from the ASF dual-hosted git repository.
lizhanhui 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 9db648c5d [ISSUE #4921] Fix wrong log output in TimerMessageStore
(#4922)
9db648c5d is described below
commit 9db648c5d93e7c63282e890acf0cbc9a149c974f
Author: rongtong <[email protected]>
AuthorDate: Mon Aug 29 20:05:45 2022 +0800
[ISSUE #4921] Fix wrong log output in TimerMessageStore (#4922)
* Fix wrong log output in TimerMessageStore
* Modify the output level of log to debug
---
.../main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java | 5 ++---
1 file changed, 2 insertions(+), 3 deletions(-)
diff --git
a/store/src/main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java
b/store/src/main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java
index ac0facff7..0bdd42e74 100644
--- a/store/src/main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java
+++ b/store/src/main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java
@@ -240,12 +240,11 @@ public class TimerMessageStore {
Slot slotEach = timerWheel.getSlot(currTime + j * precisionMs);
periodTotal += slotEach.num;
}
- LOGGER.info("%d period's total num: %d\n", timerDist.get(i),
periodTotal);
+ LOGGER.debug("{} period's total num: {}", timerDist.get(i),
periodTotal);
this.timerMetrics.updateDistPair(timerDist.get(i), periodTotal);
}
long endTime = System.currentTimeMillis();
- LOGGER.info("Total cost Time:%d%n", endTime - startTime);
-
+ LOGGER.debug("Total cost Time: {}", endTime - startTime);
}
public void recover() {
