Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

[#7283] Incorrect dledger commitlog min offset after mappedFile re delete failed #7284

Merged
merged 12 commits into from
Aug 31, 2023
Merged

[#7283] Incorrect dledger commitlog min offset after mappedFile re delete failed #7284

Changes from all commits
Commits
Show all changes
12 commits
Select commit Hold shift + click to select a range
2c4718e
[ISSUE #6390] Add break to the exception of WHEEL_TIMER_NOT_ENABLE.
yuz10 Mar 27, 2023
c89dd47
Merge branch 'apache:develop' into develop2
yuz10 Jun 14, 2023
3364cb8
fix broker start fail if mapped file size is 0
yuz10 Jun 14, 2023
5ec2fee
log
yuz10 Jun 14, 2023
e8aa1f8
only delete the last empty file
yuz10 Jun 15, 2023
38d15fd
Merge branch 'apache:develop' into develop2
yuz10 Jun 22, 2023
23d1c32
Merge branch 'apache:develop' into develop2
yuz10 Jun 25, 2023
15aa07e
change dataReadAheadEnable default to true
yuz10 Jun 25, 2023
aff4afc
Merge branch 'apache:develop' into develop2
yuz10 Aug 26, 2023
41b62d5
fix endless loop when master change to slave.
yuz10 Aug 26, 2023
26fde6b
Merge branch 'apache:develop' into develop2
yuz10 Aug 30, 2023
52746f7
[#7283] get min offset should return the first available file's offset.
yuz10 Aug 30, 2023
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 6 additions & 1 deletion store/src/main/java/org/apache/rocketmq/store/dledger/DLedgerCommitLog.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -162,7 +162,12 @@ public long getMinOffset() {
if (!mappedFileQueue.getMappedFiles().isEmpty()) {
return mappedFileQueue.getMinOffset();
}
return dLedgerFileList.getMinOffset();
for (MmapFile file : dLedgerFileList.getMappedFiles()) {
if (file.isAvailable()) {
return file.getFileFromOffset() + file.getStartPosition();
}
}
return 0;
}

@Override
Expand Down
Loading