denis-chudov commented on code in PR #2036:
URL: https://github.com/apache/ignite-3/pull/2036#discussion_r1187313316
##########
modules/replicator/src/main/java/org/apache/ignite/internal/replicator/ReplicaManager.java:
##########
@@ -222,6 +267,29 @@ private void
onPlacementDriverMessageReceived(NetworkMessage msg0, String sender
}
}
+ /**
+ * Sends stop lease prolongation message to all participants of placement
driver group.
+ *
+ * @param groupId Replication group id.
+ * @param redirectNodeId Node consistent id to redirect.
+ */
+ private void declineLeaseProlongation(ReplicationGroupId groupId, String
redirectNodeId) {
+ LOG.info("The replica does not meet the requirements for the
leaseholder [groupId={}, redirectNodeId={}]", groupId, redirectNodeId);
+
+ msNodes.thenAccept(nodeIds -> {
Review Comment:
also, the leaderFuture on replica must be reset in order to hold on next
LeaseGrantedMessage and wait for the next leader election
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
