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 cd7940e87d5..97833351d19 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 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