IGNITE-24963 Try WD

Author: ascherbakoff

modules/table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/PartitionReplicaListener.java

@@ -2980,6 +2980,7 @@ private CompletableFuture<ReplicaResult> processSingleEntryAction(ReadWriteSingl
                 });
             }
             case RW_UPSERT: {
+                // TODO IGNITE-28450
                 return resolveRowByPk(extractPk(searchRow), txId, (rowId, row, lastCommitTime) -> {
                     boolean insert = rowId == null;
 

modules/transactions/src/main/java/org/apache/ignite/internal/tx/impl/TxManagerImpl.java

@@ -1036,27 +1036,35 @@ public void processDelayedAck(Object ignored, @Nullable Throwable err) {
 
     @Override
     public CompletableFuture<Void> startAsync(ComponentContext componentContext) {
-        var deadlockPreventionPolicy = new WoundWaitDeadlockPreventionPolicy() {
+//        var deadlockPreventionPolicy = new WoundWaitDeadlockPreventionPolicy() {
+//            @Override
+//            public long waitTimeout() {
+//                return DEFAULT_LOCK_TIMEOUT;
+//            }
+//
+//            @Override
+//            public void failAction(UUID owner) {
+//                // TODO IGNITE-28447 sendTxRecoveryMessage and delete locks.
+//                TxStateMeta state = txStateVolatileStorage.state(owner);
+//                if (state == null || state.txCoordinatorId() == null) {
+//                    return; // Tx state is invalid. Locks will be cleaned up by tx recovery process.
+//                }
+//
+//                InternalClusterNode coordinator = topologyService.getById(state.txCoordinatorId());
+//                if (coordinator == null) {
+//                    return; // Tx is abandoned. Locks will be cleaned up by tx recovery process.
+//                }
+//
+//                txMessageSender.kill(coordinator, owner);
+//            }
+//        };
+
+        // This commented section is left intentionally.
+        var deadlockPreventionPolicy = new WaitDieDeadlockPreventionPolicy() {
             @Override
             public long waitTimeout() {
                 return DEFAULT_LOCK_TIMEOUT;
             }
-
-            @Override
-            public void failAction(UUID owner) {
-                // TODO IGNITE-28447 sendTxRecoveryMessage and delete locks.
-                TxStateMeta state = txStateVolatileStorage.state(owner);
-                if (state == null || state.txCoordinatorId() == null) {
-                    return; // Tx state is invalid. Locks will be cleaned up by tx recovery process.
-                }
-
-                InternalClusterNode coordinator = topologyService.getById(state.txCoordinatorId());
-                if (coordinator == null) {
-                    return; // Tx is abandoned. Locks will be cleaned up by tx recovery process.
-                }
-
-                txMessageSender.kill(coordinator, owner);
-            }
         };
 
         txStateVolatileStorage.start();