opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-08-31 02:20:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ISSUE#4917] Optimize the retry logic in appending a no-op request when controller change to leader (#4918)

Browse Source
This commit is contained in:
TheR1sing3un
2022-08-30 08:43:03 +08:00
committed by GitHub
parent cf74c3cd8b
commit 6a8b1aa96b
1 changed files with 10 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
controller/src/main/java/org/apache/rocketmq/controller/impl/DLedgerController.java
+10 -4
View File
@@ -440,10 +440,16 @@ public class DLedgerController implements Controller {
}
} catch (final Throwable e) {
log.error("Error happen when controller leader append initial request to dledger", e);
tryTimes++;
if (tryTimes % 3 == 0) {
log.warn("Controller leader append initial log failed too many times, please wait a while");
}
}
if (!DLedgerController.this.getMemberState().isLeader()) {
// now is not a leader
log.error("Append a initial log failed because current state is not leader");
break;
}
tryTimes++;
log.error(String.format("Controller leader append initial log failed, try %d times", tryTimes));
if (tryTimes % 3 == 0) {
log.warn("Controller leader append initial log failed too many times, please wait a while");
}
}
break;