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);