opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-08-30 18:10:44 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ISSUE #7836] flush_behind_bytes wrong in transientStorePoolEnable not enable

Browse Source
This commit is contained in:
Lei Zhiyuan
2024-03-24 18:58:19 +08:00
committed by GitHub
parent f2dd5b06fe
commit 27d8375940
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
+5 -1
View File
@@ -1543,7 +1543,11 @@ public class DefaultMessageStore implements MessageStore {
}
public long flushBehindBytes() {
return this.commitLog.remainHowManyDataToCommit() + this.commitLog.remainHowManyDataToFlush();
if (this.messageStoreConfig.isTransientStorePoolEnable()) {
return this.commitLog.remainHowManyDataToCommit() + this.commitLog.remainHowManyDataToFlush();
} else {
return this.commitLog.remainHowManyDataToFlush();
}
}
@Override