This is an automated email from the ASF dual-hosted git repository.

vpyatkov pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git


The following commit(s) were added to refs/heads/main by this push:
     new c57c1a8c38 IGNITE-22024 Fixed 
ItSqlClientSynchronousApiTest#runtimeErrorInDmlCausesTransactionToFail (#3651)
c57c1a8c38 is described below

commit c57c1a8c383858828717580db13736e708095292
Author: Denis Chudov <moongll...@gmail.com>
AuthorDate: Tue Apr 23 14:39:28 2024 +0300

    IGNITE-22024 Fixed 
ItSqlClientSynchronousApiTest#runtimeErrorInDmlCausesTransactionToFail (#3651)
---
 .../distributed/replicator/PartitionReplicaListener.java   | 14 ++++++--------
 1 file changed, 6 insertions(+), 8 deletions(-)

diff --git 
a/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/PartitionReplicaListener.java
 
b/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/PartitionReplicaListener.java
index 45ced734e9..b4589a0f5b 100644
--- 
a/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/PartitionReplicaListener.java
+++ 
b/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/PartitionReplicaListener.java
@@ -3915,14 +3915,12 @@ public class PartitionReplicaListener implements 
ReplicaListener {
     private void markFinished(UUID txId, TxState txState, @Nullable 
HybridTimestamp commitTimestamp) {
         assert isFinalState(txState) : "Unexpected state [txId=" + txId + ", 
txState=" + txState + ']';
 
-        txManager.updateTxMeta(txId, old -> old == null
-                ? null
-                : new TxStateMeta(
-                        txState,
-                        old.txCoordinatorId(),
-                        old.commitPartitionId(),
-                        txState == COMMITTED ? commitTimestamp : null
-                ));
+        txManager.updateTxMeta(txId, old -> new TxStateMeta(
+                txState,
+                old == null ? null : old.txCoordinatorId(),
+                old == null ? null : old.commitPartitionId(),
+                txState == COMMITTED ? commitTimestamp : null
+        ));
     }
 
     // TODO: https://issues.apache.org/jira/browse/IGNITE-20124 Temporary code 
below

Reply via email to