fix

Author: zstan

modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishFuture.java

@@ -999,10 +999,12 @@ ClusterNode primary() {
                                         try {
                                             cctx.io().send(backup, req, tx.ioPolicy());
 
-                                            if (salvageReq == null)
-                                                salvageReq = new GridDhtTxSalvageMessage(tx.xidVersion());
+                                            if (tx.storeWriteThrough()) {
+                                                if (salvageReq == null)
+                                                    salvageReq = new GridDhtTxSalvageMessage(tx.xidVersion());
 
-                                            cctx.io().send(backup, salvageReq, tx.ioPolicy());
+                                                cctx.io().send(backup, salvageReq, tx.ioPolicy());
+                                            }
                                         }
                                         catch (ClusterTopologyCheckedException ignored) {
                                             mini.onNodeLeft(backupId, discoThread);

modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxHandler.java

@@ -1354,6 +1354,7 @@ private void processDhtTxSalvageRequest(GridDhtTxSalvageMessage req) {
                 // GridDhtTxLocal possible
                 if (active instanceof GridDhtTxRemote) {
                     ctx.tm().salvageTx(active);
+                    break;
                 }
             }
         }