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