# sprint-2 Invalid assert, send can fail with ClusterTopologyCheckedException before discovery is notified
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/3462d744 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/3462d744 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/3462d744 Branch: refs/heads/ignite-573 Commit: 3462d7446889cebd7bc973fb019cd1358cdf7acc Parents: 2126914 Author: sboikov <sboi...@gridgain.com> Authored: Wed Mar 25 12:23:28 2015 +0300 Committer: sboikov <sboi...@gridgain.com> Committed: Wed Mar 25 12:23:28 2015 +0300 ---------------------------------------------------------------------- .../cache/distributed/dht/GridPartitionedGetFuture.java | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/3462d744/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridPartitionedGetFuture.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridPartitionedGetFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridPartitionedGetFuture.java index 45dae66..d9c1f3c 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridPartitionedGetFuture.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridPartitionedGetFuture.java @@ -400,7 +400,7 @@ public class GridPartitionedGetFuture<K, V> extends GridCompoundIdentityFuture<M @SuppressWarnings("ConstantConditions") private boolean map( KeyCacheObject key, - Map<ClusterNode, LinkedHashMap<KeyCacheObject, Boolean>> mappings, + Map<ClusterNode, LinkedHashMap<KeyCacheObject, Boolean>> mappings, Map<K, V> locVals, AffinityTopologyVersion topVer, Map<ClusterNode, LinkedHashMap<KeyCacheObject, Boolean>> mapped @@ -608,10 +608,6 @@ public class GridPartitionedGetFuture<K, V> extends GridCompoundIdentityFuture<M AffinityTopologyVersion updTopVer = new AffinityTopologyVersion(cctx.discovery().topologyVersion()); - assert updTopVer.compareTo(topVer) > 0 : "Got topology exception but topology version did " + - "not change [topVer=" + topVer + ", updTopVer=" + updTopVer + - ", nodeId=" + node.id() + ']'; - // Remap. map(keys.keySet(), F.t(node, keys), updTopVer);
