This is an automated email from the ASF dual-hosted git repository. av pushed a commit to branch ignite-20177 in repository https://gitbox.apache.org/repos/asf/ignite.git
commit 955a881717fa8ca194d01b8bd03d9796f295fe00 Author: Anton Vinogradov <a...@apache.org> AuthorDate: Tue Aug 8 16:08:46 2023 +0300 WIP --- .../cache/distributed/near/GridNearTxFinishFuture.java | 13 ++++++------- 1 file changed, 6 insertions(+), 7 deletions(-) diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishFuture.java index e30e9d571a6..b16aa312967 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishFuture.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishFuture.java @@ -537,13 +537,12 @@ public final class GridNearTxFinishFuture<K, V> extends GridCacheCompoundIdentit ClusterNode backup = cctx.discovery().node(backupId); // Nothing to do if backup has left the grid. - if (backup == null) { - // No-op. + if (backup != null) { + if (backup.isLocal()) + cctx.tm().removeTxReturn(tx.xidVersion()); + else + cctx.tm().sendDeferredAckResponse(backupId, tx.xidVersion()); } - else if (backup.isLocal()) - cctx.tm().removeTxReturn(tx.xidVersion()); - else - cctx.tm().sendDeferredAckResponse(backupId, tx.xidVersion()); } } } @@ -928,7 +927,7 @@ public final class GridNearTxFinishFuture<K, V> extends GridCacheCompoundIdentit /** * */ - private abstract class MinFuture extends GridFutureAdapter<IgniteInternalTx> { + private abstract static class MinFuture extends GridFutureAdapter<IgniteInternalTx> { /** */ private final int futId;