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;