opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-08-31 02:20:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ISSUE #8438] Fix broker return two messages when query message and index service bug (#8439)

Browse Source
This commit is contained in:
lizhimins
2024-07-25 11:38:31 +08:00
committed by GitHub
parent 6e6319f11a
commit c080e6bbf2
3 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/TieredMessageStore.java
+3
View File
@@ -460,6 +460,9 @@ public class TieredMessageStore extends AbstractPluginMessageStore {
if (flatFileStore != null) {
flatFileStore.shutdown();
}
if (indexService != null) {
indexService.shutdown();
}
if (storeExecutor != null) {
storeExecutor.shutdown();
}
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatAppendFile.java
+1
View File
@@ -90,6 +90,7 @@ public class FlatAppendFile {
public void initOffset(long offset) {
if (this.fileSegmentTable.isEmpty()) {
FileSegment fileSegment = fileSegmentFactory.createSegment(fileType, filePath, offset);
fileSegment.initPosition(fileSegment.getSize());
this.flushFileSegmentMeta(fileSegment);
this.fileSegmentTable.add(fileSegment);
}
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/index/IndexStoreFile.java
+3 -1
View File
@@ -287,7 +287,9 @@ public class IndexStoreFile implements IndexFile {
buffer.position(this.getItemPosition(slotValue));
buffer.get(bytes);
IndexItem indexItem = new IndexItem(bytes);
if (hashCode == indexItem.getHashCode()) {
long storeTimestamp = indexItem.getTimeDiff() + beginTimestamp.get();
if (hashCode == indexItem.getHashCode() &&
beginTime <= storeTimestamp && storeTimestamp <= endTime) {
result.add(indexItem);
if (result.size() > maxCount) {
break;