Repository: ignite Updated Branches: refs/heads/ignite-3477-master 9129b7428 -> 00c0f322d
IGNITE-3477 - Fixed assertion on validateTopology Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/00c0f322 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/00c0f322 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/00c0f322 Branch: refs/heads/ignite-3477-master Commit: 00c0f322dd3c6ca0569dfa41ecab8e13d9cdbb29 Parents: 9129b74 Author: Alexey Goncharuk <[email protected]> Authored: Mon Mar 27 12:19:08 2017 +0300 Committer: Alexey Goncharuk <[email protected]> Committed: Mon Mar 27 12:19:08 2017 +0300 ---------------------------------------------------------------------- .../near/GridNearOptimisticTxPrepareFutureAdapter.java | 13 ------------- 1 file changed, 13 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/00c0f322/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearOptimisticTxPrepareFutureAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearOptimisticTxPrepareFutureAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearOptimisticTxPrepareFutureAdapter.java index 1d610c7..f09b6c8 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearOptimisticTxPrepareFutureAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearOptimisticTxPrepareFutureAdapter.java @@ -62,19 +62,6 @@ public abstract class GridNearOptimisticTxPrepareFutureAdapter extends GridNearT } if (topVer != null) { - try { - IgniteCheckedException err = tx.txState().validateTopology(cctx, false, topologyReadLock()); - - if (err != null) { - onDone(err); - - return; - } - } - finally { - topologyReadUnlock(); - } - tx.topologyVersion(topVer); cctx.mvcc().addFuture(this);
