dengziming commented on a change in pull request #9531:
URL: https://github.com/apache/kafka/pull/9531#discussion_r516385415
##########
File path: raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java
##########
@@ -1560,9 +1558,34 @@ private long pollLeader(long currentTimeMs) {
return Math.min(timeUntilFlush, timeUntilSend);
}
+ private long maybeSendVoteRequests(
+ CandidateState state,
+ long currentTimeMs
+ ) {
+ // Continue sending Vote requests as long as we still have a chance to
win the election
+ if (!state.isVoteRejected()) {
+ return maybeSendRequests(
+ currentTimeMs,
+ state.unrecordedVoters(),
+ this::buildVoteRequest
+ );
+ }
+ return Long.MAX_VALUE;
+ }
+
private long pollCandidate(long currentTimeMs) throws IOException {
CandidateState state = quorum.candidateStateOrThrow();
- if (state.isBackingOff()) {
+ GracefulShutdown shutdown = this.shutdown.get();
+
+ if (shutdown != null) {
+ // If we happen to shutdown while we are a candidate, we will
continue
+ // with the current election until one of the following conditions
is met:
+ // 1) we are elected as leader (which allows us to resign)
+ // 2) another leader is elected
+ // 3) the shutdown timer expires
+ long minRequestBackoffMs = maybeSendVoteRequests(state,
currentTimeMs);
+ return Math.min(shutdown.remainingTimeMs(), minRequestBackoffMs);
Review comment:
Understand, The candidate will try to complete only the current election
when shutting down, so just ignore the election timeout.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
