Details
-
Task
-
Status: Resolved
-
Blocker
-
Resolution: Fixed
-
None
-
None
Description
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()); }
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.
Attachments
Attachments
Issue Links
- blocks
-
IGNITE-16265 Integration SQL Index and data storage
- Resolved
- links to