vldpyatkov commented on code in PR #2832:
URL: https://github.com/apache/ignite-3/pull/2832#discussion_r1395946326
##########
modules/transactions/src/main/java/org/apache/ignite/internal/tx/impl/TxManagerImpl.java:
##########
@@ -349,9 +332,17 @@ public CompletableFuture<Void> finish(
// than all the read timestamps processed before.
// Every concurrent operation will now use a finish future from the
finishing state meta and get only final transaction
// state after the transaction is finished.
- TxStateMetaFinishing finishingStateMeta = new
TxStateMetaFinishing(coordinatorId());
+ AtomicReference<TxStateMetaFinishing> finishingStateMetaRef = new
AtomicReference<>();
+
+ updateTxMeta(txId, old -> {
+ var finishingState = new TxStateMetaFinishing(localNodeId, old ==
null ? null : old.commitPartitionId());
- updateTxMeta(txId, old -> finishingStateMeta);
+ finishingStateMetaRef.set(finishingState);
+
+ return finishingState;
+ });
Review Comment:
It is not related to the patch.
--
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]
