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/06/02 09:54:03 UTC
[rocketmq] branch 5.0.0-beta-dledger-controller updated: [Summer of code] Fix allAckSyncStateSet not working
This is an automated email from the ASF dual-hosted git repository.
jinrongtong pushed a commit to branch 5.0.0-beta-dledger-controller
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/5.0.0-beta-dledger-controller by this push:
new c4a7acdc0 [Summer of code] Fix allAckSyncStateSet not working
c4a7acdc0 is described below
commit c4a7acdc0d6b2adab83bf7235402a042237ce228
Author: hzh0425 <64...@qq.com>
AuthorDate: Thu Jun 2 17:53:49 2022 +0800
[Summer of code] Fix allAckSyncStateSet not working
---
.../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 67ada60dd..02198ad05 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
@@ -99,7 +99,7 @@ public class GroupTransferService extends ServiceThread {
int ackNums = 1;
for (HAConnection conn : haService.getConnectionList()) {
final AutoSwitchHAConnection autoSwitchHAConnection = (AutoSwitchHAConnection) conn;
- if (syncStateSet.contains(autoSwitchHAConnection.getClientAddress()) && autoSwitchHAConnection.getSlaveAckOffset() >= req.getNextOffset()) {
+ if (syncStateSet.contains(autoSwitchHAConnection.getSlaveAddress()) && autoSwitchHAConnection.getSlaveAckOffset() >= req.getNextOffset()) {
ackNums ++;
}
if (ackNums >= syncStateSet.size()) {