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 <[email protected]>
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++;

Reply via email to