Alexander Lapin created IGNITE-16624:
----------------------------------------

             Summary: tx state doesn't replicate within raft group if tx 
coordinator is collocated with corresponding raft leader
                 Key: IGNITE-16624
                 URL: https://issues.apache.org/jira/browse/IGNITE-16624
             Project: Ignite
          Issue Type: Task
            Reporter: Alexander Lapin


{code:java}
private CompletableFuture<Void> finish(boolean commit) {
    ...
    for (Map.Entry<NetworkAddress, Set<String>> entry : tmp.entrySet()) {
        boolean local = address.equals(entry.getKey());

        futs[i++] = local ? commit ? txManager.commitAsync(timestamp) : 
txManager.rollbackAsync(timestamp) :
                txManager.finishRemote(entry.getKey(), timestamp, commit, 
entry.getValue());
    }

 {code}
If local is false txManager.finishRemote() will be called that’ll be replicate 
txState over all raft group members.However if local is true we will only 
change txState locally.



--
This message was sent by Atlassian Jira
(v8.20.1#820001)

Reply via email to