ascherbakoff commented on code in PR #7566:
URL: https://github.com/apache/ignite-3/pull/7566#discussion_r2791570320
##########
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/PartitionReplicaListener.java:
##########
@@ -1417,6 +1417,20 @@ private CompletableFuture<Void> continueIndexLookup(
}
private CompletableFuture<ReplicaResult>
processTableWriteIntentSwitchAction(TableWriteIntentSwitchReplicaRequest
request) {
+ TxStateMeta txStateMeta = txManager.stateMeta(request.txId());
+
+ if (txStateMeta != null && txStateMeta.txState() == ABORTED) {
+ // At this point a transaction is marked as finished, preventing
new locks.
+ // Safe to invalidate waiters, which otherwise will block the
cleanup process.
+ // Using non-retriable exception intentionally to prevent
unnecessary retries.
+ // This adds additional latency on commit path, which should go
away after implementing async write intent cleanup.
Review Comment:
🆗
--
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]
