File tree Expand file tree Collapse file tree
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/index Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -285,7 +285,7 @@ protected CompletableFuture<List<IndexItem>> queryAsyncFromUnsealedFile(
285285 buffer .position (this .getItemPosition (slotValue ));
286286 buffer .get (bytes );
287287 IndexItem indexItem = new IndexItem (bytes );
288- long storeTimestamp = indexItem .getTimeDiff () + beginTimestamp .get ();
288+ long storeTimestamp = indexItem .getTimeDiff () * 1000L + beginTimestamp .get ();
289289 if (hashCode == indexItem .getHashCode () &&
290290 beginTime <= storeTimestamp && storeTimestamp <= endTime ) {
291291 result .add (indexItem );
@@ -353,7 +353,7 @@ protected CompletableFuture<List<IndexItem>> queryAsyncFromSegmentFile(
353353 for (int i = 0 ; i < size ; i ++) {
354354 itemBuffer .get (bytes );
355355 IndexItem indexItem = new IndexItem (bytes );
356- long storeTimestamp = indexItem .getTimeDiff () + beginTimestamp .get ();
356+ long storeTimestamp = indexItem .getTimeDiff () * 1000L + beginTimestamp .get ();
357357 if (hashCode == indexItem .getHashCode () &&
358358 beginTime <= storeTimestamp && storeTimestamp <= endTime &&
359359 result .size () < maxCount ) {
You can’t perform that action at this time.
0 commit comments