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