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

ShannonDing 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 cbebac2e66 [ISSUE #10819] Correct misleading CommitLog buffer comment 
(#10820)
cbebac2e66 is described below

commit cbebac2e66bf44b0e81c2ef09beba2f2a9e11bf4
Author: fuyou001 <[email protected]>
AuthorDate: Thu Aug 6 16:33:59 2026 +0800

    [ISSUE #10819] Correct misleading CommitLog buffer comment (#10820)
    
    * [ISSUE #10819] Correct misleading CommitLog buffer comment
    
    * [ISSUE #10819] Refine CommitLog comment wording
---
 store/src/main/java/org/apache/rocketmq/store/CommitLog.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/store/src/main/java/org/apache/rocketmq/store/CommitLog.java 
b/store/src/main/java/org/apache/rocketmq/store/CommitLog.java
index 260f021aed..f4eec36853 100644
--- a/store/src/main/java/org/apache/rocketmq/store/CommitLog.java
+++ b/store/src/main/java/org/apache/rocketmq/store/CommitLog.java
@@ -2092,7 +2092,7 @@ public class CommitLog implements Swappable {
 
             final long beginTimeMills = 
CommitLog.this.defaultMessageStore.now();
             
CommitLog.this.getMessageStore().getPerfCounter().startTick("WRITE_MEMORY_TIME_MS");
-            // Write messages to the queue buffer
+            // Append the encoded message to the current CommitLog buffer
             byteBuffer.put(preEncodeBuffer);
             
CommitLog.this.getMessageStore().getPerfCounter().endTick("WRITE_MEMORY_TIME_MS");
             msgInner.setEncodedBuff(null);

Reply via email to