Denis Chudov created IGNITE-27255:
-------------------------------------
Summary: TxIdMismatchException due to possible concurrent write
intent insertion after resolution before locking
Key: IGNITE-27255
URL: https://issues.apache.org/jira/browse/IGNITE-27255
Project: Ignite
Issue Type: Bug
Reporter: Denis Chudov
This happens on the processing of single row request:
{code:java}
2025-12-03 19:43:07:418 +0000
[WARNING][%cac-dpd-cde-gg-aks-dev-2%partition-operations-3][ReplicaManager]
Failed to process replica request [request=ReadWriteSingleRowReplicaRequestImpl
[commitPartitionId=ZonePartitionIdMessageImpl [partitionId=19, zoneId=24],
coordinatorId=7fa86716-8652-42df-a7b1-8e8b55f19cf9, delayedAckProcessor=null,
enlistmentConsistencyToken=115657324018139159, full=false,
groupId=ZonePartitionIdMessageImpl [partitionId=5, zoneId=27],
requestType=RW_UPSERT, schemaVersion=1, skipDelayedAck=false, tableId=1049,
timestamp=HybridTimestamp [physical=2025-12-03 19:42:45:567 +0000, logical=49,
composite=115657340719398961],
transactionId=019ae5bd-153f-0031-399b-326e00000001]].java.util.concurrent.CompletionException:
org.apache.ignite.internal.storage.TxIdMismatchException: IGN-CMN-65535
Mismatched transaction id [expectedTxId=019ae57c-1599-0079-399b-326e00000001,
actualTxId=019ae5bd-153f-0031-399b-326e00000001] TraceId:437a68a4 at
java.base/java.util.concurrent.CompletableFuture.encodeThrowable(Unknown
Source) at
java.base/java.util.concurrent.CompletableFuture.completeThrowable(Unknown
Source) at
java.base/java.util.concurrent.CompletableFuture$UniCompose.tryFire(Unknown
Source) at
java.base/java.util.concurrent.CompletableFuture.postComplete(Unknown Source)
at java.base/java.util.concurrent.CompletableFuture.postFire(Unknown Source)
at java.base/java.util.concurrent.CompletableFuture$UniApply.tryFire(Unknown
Source) at
java.base/java.util.concurrent.CompletableFuture$Completion.run(Unknown Source)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown
Source) at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
at java.base/java.lang.Thread.run(Unknown Source)Caused by:
org.apache.ignite.internal.storage.TxIdMismatchException: IGN-CMN-65535
Mismatched transaction id [expectedTxId=019ae57c-1599-0079-399b-326e00000001,
actualTxId=019ae5bd-153f-0031-399b-326e00000001] TraceId:437a68a4 at
org.apache.ignite.internal.table.distributed.StorageUpdateHandler.performAddWriteWithCleanup(StorageUpdateHandler.java:484)
at
org.apache.ignite.internal.table.distributed.StorageUpdateHandler.tryProcessRow(StorageUpdateHandler.java:173)
at
org.apache.ignite.internal.table.distributed.StorageUpdateHandler.lambda$handleUpdate$0(StorageUpdateHandler.java:123)
at
org.apache.ignite.internal.storage.pagememory.mv.PersistentPageMemoryMvPartitionStorage.lambda$runConsistently$0(PersistentPageMemoryMvPartitionStorage.java:187)
at
org.apache.ignite.internal.storage.pagememory.mv.AbstractPageMemoryMvPartitionStorage.busy(AbstractPageMemoryMvPartitionStorage.java:1062)
at
org.apache.ignite.internal.storage.pagememory.mv.PersistentPageMemoryMvPartitionStorage.runConsistently(PersistentPageMemoryMvPartitionStorage.java:177)
at
org.apache.ignite.internal.table.distributed.raft.snapshot.SnapshotAwarePartitionDataStorage.runConsistently(SnapshotAwarePartitionDataStorage.java:84)
at
org.apache.ignite.internal.table.distributed.StorageUpdateHandler.handleUpdate(StorageUpdateHandler.java:120)
at
org.apache.ignite.internal.table.distributed.replicator.PartitionReplicaListener.applyUpdateCommand(PartitionReplicaListener.java:3275)
at
org.apache.ignite.internal.table.distributed.replicator.PartitionReplicaListener.applyUpdateCommand(PartitionReplicaListener.java:3347)
at
org.apache.ignite.internal.table.distributed.replicator.PartitionReplicaListener.lambda$processSingleEntryAction$160(PartitionReplicaListener.java:3664)
... 8 more {code}
The code:
{code:java}
case RW_UPSERT: {
return resolveRowByPk(extractPk(searchRow), txId, (rowId, row,
lastCommitTime) -> {
boolean insert = rowId == null;
RowId rowId0 = insert ? new RowId(partId(), RowIdGenerator.next()) :
rowId;
CompletableFuture<IgniteBiTuple<RowId, Collection<Lock>>> lockFut =
insert
? takeLocksForInsert(searchRow, rowId0, txId)
: takeLocksForUpdate(searchRow, rowId0, txId);
{code}
Exception is thrown in thenCompose of lockFut.
Possible scenario: after write intent resolution (inside resolveRowByPk)
another transaction inserts new write intent to the same row concurrently, then
finishes and releases lock, but WI is still not switched. The current
transaction acquires lock successfully but fails to write the row because of WI
of another txn.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
