(rocketmq) branch develop updated: [ISSUE #7836] flush_behind_bytes wrong in transientStorePoolEnable not enable

[jinrongtong]

This is an automated email from the ASF dual-hosted git repository.

jinrongtong pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new 27d8375940 [ISSUE #7836] flush_behind_bytes wrong in 
transientStorePoolEnable not enable
27d8375940 is described below

commit 27d8375940dfd248bd9c2d00b5a64607653a1504
Author: Lei Zhiyuan <leizhiy...@gmail.com>
AuthorDate: Sun Mar 24 18:58:19 2024 +0800

    [ISSUE #7836] flush_behind_bytes wrong in transientStorePoolEnable not 
enable
---
 .../main/java/org/apache/rocketmq/store/DefaultMessageStore.java    | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git 
a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java 
b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
index cd7940e87d..97833351d1 100644
--- a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
+++ b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
@@ -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