You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by ji...@apache.org on 2022/04/10 02:35:36 UTC
[rocketmq] branch 5.0.0-beta updated: Polish the comment
This is an automated email from the ASF dual-hosted git repository.
jinrongtong pushed a commit to branch 5.0.0-beta
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/5.0.0-beta by this push:
new 61e0f0cae Polish the comment
61e0f0cae is described below
commit 61e0f0cae9323572196a66b4d38ae4e8ed51f50f
Author: RongtongJin <ji...@mails.ucas.ac.cn>
AuthorDate: Sun Apr 10 10:35:01 2022 +0800
Polish the comment
---
.../main/java/org/apache/rocketmq/store/ha/GroupTransferService.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/store/src/main/java/org/apache/rocketmq/store/ha/GroupTransferService.java b/store/src/main/java/org/apache/rocketmq/store/ha/GroupTransferService.java
index 4bfb40613..b1c48ca21 100644
--- a/store/src/main/java/org/apache/rocketmq/store/ha/GroupTransferService.java
+++ b/store/src/main/java/org/apache/rocketmq/store/ha/GroupTransferService.java
@@ -84,7 +84,7 @@ public class GroupTransferService extends ServiceThread {
int ackNums = 0;
for (HAConnection conn : haService.getConnectionList()) {
- // TODO: We must ensure every AutoRecoverHAConnection represents a different slave
+ // TODO: We must ensure every HAConnection represents a different slave
// Solution: Consider assign a unique and fixed IP:ADDR for each different slave
if (conn.getSlaveAckOffset() >= req.getNextOffset()) {
ackNums++;