Skip to content

Commit ef55749

Browse files
committed
last failed test fix
1 parent d2bb726 commit ef55749

1 file changed

Lines changed: 5 additions & 1 deletion

File tree

  • modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht

modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtTxLocal.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -460,8 +460,12 @@ else if (!lockFut.isDone()) {
460460
logTxFinishErrorSafe(log, commit, e);
461461

462462
// Treat heuristic exception as critical.
463-
if (X.hasCause(e, IgniteTxHeuristicCheckedException.class))
463+
if (X.hasCause(e, IgniteTxHeuristicCheckedException.class)) {
464+
if (storeWriteThrough() && local())
465+
salvageTx();
466+
464467
cctx.kernalContext().failure().process(new FailureContext(FailureType.CRITICAL_ERROR, e));
468+
}
465469

466470
err = e;
467471
}

0 commit comments

Comments
 (0)