[ 
https://issues.apache.org/jira/browse/IGNITE-19471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Kirill Gusakov updated IGNITE-19471:
------------------------------------
    Description: 
Algorithm:
 * TableManager receives the pending keys update inside the pending keys 
listener: TableManager check if the current node is a leader of partition and 
send the RebalanceRequest to PrimaryReplica through ReplicaService (TODO: do we 
have an ability to send the message to PrimaryReplica directly?)
 * PrimaryReplica receives this message and initiate the changePeers command to 
the leader of RAFT group (TODO: should this call be protected by the leaderTerm 
as the current call inside the TableManager?)

Other scenarios:
 * onLeadeElected eventĀ RebalanceRaftGroupEventsListener must send the 
RebalanceRequest message to PrimaryReplica instead of direct call of 
changePeersAsync
 * onReconfigurationError event listener RebalanceRaftGroupEventsListener must 
send the RebalanceRequest also.

  was:
Algorithm:
 * TableManager receives the pending keys update inside the pending keys 
listener: TableManager check if the current node is a leader of partition and 
send the RebalanceRequest to PrimaryReplica throight ReplicaService (TODO: do 
we have an ability to send the message to PrimaryReplica directly?)
 * PrimaryReplica receives this message and initiate the changePeers command to 
the leader of RAFT group (TODO: should this call be protected by the leaderTerm 
as the current call inside the TableManager?)

Other scenarios:
 * onLeadeElected eventĀ RebalanceRaftGroupEventsListener must send the 
RebalanceRequest message to PrimaryReplica instead of direct call of 
changePeersAsync
 * onReconfigurationError event listener RebalanceRaftGroupEventsListener must 
send the RebalanceRequest also.


> Move changePeers calls logic to PrimaryReplica
> ----------------------------------------------
>
>                 Key: IGNITE-19471
>                 URL: https://issues.apache.org/jira/browse/IGNITE-19471
>             Project: Ignite
>          Issue Type: Task
>            Reporter: Kirill Gusakov
>            Priority: Major
>
> Algorithm:
>  * TableManager receives the pending keys update inside the pending keys 
> listener: TableManager check if the current node is a leader of partition and 
> send the RebalanceRequest to PrimaryReplica through ReplicaService (TODO: do 
> we have an ability to send the message to PrimaryReplica directly?)
>  * PrimaryReplica receives this message and initiate the changePeers command 
> to the leader of RAFT group (TODO: should this call be protected by the 
> leaderTerm as the current call inside the TableManager?)
> Other scenarios:
>  * onLeadeElected eventĀ RebalanceRaftGroupEventsListener must send the 
> RebalanceRequest message to PrimaryReplica instead of direct call of 
> changePeersAsync
>  * onReconfigurationError event listener RebalanceRaftGroupEventsListener 
> must send the RebalanceRequest also.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to