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

duhengforever 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 21fb9084a [ISSUE #4920]Fix comment word typo (#4928)
21fb9084a is described below

commit 21fb9084acf9fccf1b552ab223c44208ec6c2ef7
Author: mxsm <[email protected]>
AuthorDate: Tue Aug 30 09:31:36 2022 +0800

    [ISSUE #4920]Fix comment word typo (#4928)
---
 .../org/apache/rocketmq/store/ha/autoswitch/AutoSwitchHAConnection.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/AutoSwitchHAConnection.java
 
b/store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/AutoSwitchHAConnection.java
index d920131fd..98fd77891 100644
--- 
a/store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/AutoSwitchHAConnection.java
+++ 
b/store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/AutoSwitchHAConnection.java
@@ -41,7 +41,7 @@ import org.apache.rocketmq.store.ha.io.HAWriter;
 public class AutoSwitchHAConnection implements HAConnection {
     /**
      * Header protocol in syncing msg from master. Format: current state + 
body size + offset + epoch  +
-     * epochStartOffset + additionalInfo(confirmOffset). If the msg is 
hankeShakeMsg, the body size = EpochEntrySize *
+     * epochStartOffset + additionalInfo(confirmOffset). If the msg is 
handShakeMsg, the body size = EpochEntrySize *
      * EpochEntryNums, the offset is maxOffset in master.
      */
     public static final int MSG_HEADER_SIZE = 4 + 4 + 8 + 4 + 8 + 8;

Reply via email to