(rocketmq) branch develop updated: [ISSUE #9358] Timediff should multiply 1000 when query message from tiered storage (#9359)

[lizhimin]

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 1babb32954 [ISSUE #9358] Timediff should multiply 1000 when query 
message from tiered storage (#9359)
1babb32954 is described below

commit 1babb32954995beac425a305c472883f658dbda5
Author: bxfjb <48467309+bx...@users.noreply.github.com>
AuthorDate: Wed Apr 23 10:33:49 2025 +0800

    [ISSUE #9358] Timediff should multiply 1000 when query message from tiered 
storage (#9359)
---
 .../java/org/apache/rocketmq/tieredstore/index/IndexStoreFile.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/tieredstore/src/main/java/org/apache/rocketmq/tieredstore/index/IndexStoreFile.java
 
b/tieredstore/src/main/java/org/apache/rocketmq/tieredstore/index/IndexStoreFile.java
index 25cd634873..165c0b767f 100644
--- 
a/tieredstore/src/main/java/org/apache/rocketmq/tieredstore/index/IndexStoreFile.java
+++ 
b/tieredstore/src/main/java/org/apache/rocketmq/tieredstore/index/IndexStoreFile.java
@@ -285,7 +285,7 @@ public class IndexStoreFile implements IndexFile {
                 buffer.position(this.getItemPosition(slotValue));
                 buffer.get(bytes);
                 IndexItem indexItem = new IndexItem(bytes);
-                long storeTimestamp = indexItem.getTimeDiff() + 
beginTimestamp.get();
+                long storeTimestamp = indexItem.getTimeDiff() * 1000L + 
beginTimestamp.get();
                 if (hashCode == indexItem.getHashCode() &&
                     beginTime <= storeTimestamp && storeTimestamp <= endTime) {
                     result.add(indexItem);
@@ -353,7 +353,7 @@ public class IndexStoreFile implements IndexFile {
                 for (int i = 0; i < size; i++) {
                     itemBuffer.get(bytes);
                     IndexItem indexItem = new IndexItem(bytes);
-                    long storeTimestamp = indexItem.getTimeDiff() + 
beginTimestamp.get();
+                    long storeTimestamp = indexItem.getTimeDiff() * 1000L + 
beginTimestamp.get();
                     if (hashCode == indexItem.getHashCode() &&
                         beginTime <= storeTimestamp && storeTimestamp <= 
endTime &&
                         result.size() < maxCount) {