[ISSUE #8438] Fix broker return two messages when query message and i…

…ndex service bug
apache · Jul 24, 2024 · 40ea66d · 40ea66d
1 parent dba2621
commit 40ea66d
Showing 1 changed file with 3 additions and 5 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
@@ -288,11 +288,9 @@ protected CompletableFuture<List<IndexItem>> queryAsyncFromUnsealedFile(
                     buffer.get(bytes);
                     IndexItem indexItem = new IndexItem(bytes);
                     long storeTimestamp = indexItem.getTimeDiff() + beginTimestamp.get();
-                    if (hashCode == indexItem.getHashCode()) {
-                        if (hashCode == indexItem.getHashCode() &&
-                            beginTime <= storeTimestamp && storeTimestamp <= endTime) {
-                            result.add(indexItem);
-                        }
+                    if (hashCode == indexItem.getHashCode() &&
+                        beginTime <= storeTimestamp && storeTimestamp <= endTime) {
+                        result.add(indexItem);
                         if (result.size() > maxCount) {
                             break;
                         }