From 440341b6044455b600f25cac1cf98c1f4fb5b5a8 Mon Sep 17 00:00:00 2001 From: lizhimins <707364882@qq.com> Date: Thu, 6 Nov 2025 11:37:39 +0800 Subject: [PATCH] [ISSUE #9811] Fixed the issue of excessive loop iterations in reput service (#9812) --- .../java/org/apache/rocketmq/store/DefaultMessageStore.java | 2 +- 1 file changed, 1 insertion(+), 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 7db1daa39c..cb5c41471a 100644 --- a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java +++ b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java @@ -2536,7 +2536,7 @@ public class DefaultMessageStore implements MessageStore { if (!isCommitLogAvailable) { currentReputTimestamp = System.currentTimeMillis(); } - for (boolean doNext = true; isCommitLogAvailable && doNext; ) { + for (boolean doNext = true; isCommitLogAvailable() && doNext; ) { SelectMappedBufferResult result = DefaultMessageStore.this.commitLog.getData(reputFromOffset);