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 78575af0b8 [ISSUE #8935] Fix behind metrics unit error in timer message store (#8936) 78575af0b8 is described below commit 78575af0b8ddd409ea71facceb87c144951269ae Author: Ji Juntao <juntao....@alibaba-inc.com> AuthorDate: Tue Nov 19 17:35:10 2024 +0800 [ISSUE #8935] Fix behind metrics unit error in timer message store (#8936) --- .../main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 32075474b9..071b1c0219 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 @@ -1724,7 +1724,7 @@ public class TimerMessageStore { public long getEnqueueBehindMillis() { if (System.currentTimeMillis() - lastEnqueueButExpiredTime < 2000) { - return (System.currentTimeMillis() - lastEnqueueButExpiredStoreTime) / 1000; + return System.currentTimeMillis() - lastEnqueueButExpiredStoreTime; } return 0; }