[ISSUE #7836] flush_behind_bytes wrong in transientStorePoolEnable no…

…t enable
apache · Mar 24, 2024 · 27d8375 · 27d8375
1 parent f2dd5b0
commit 27d8375
Showing 1 changed file with 5 additions and 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
@@ -1543,7 +1543,11 @@ public long dispatchBehindBytes() {
     }
 
     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