ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From anovi...@apache.org
Subject [11/32] incubator-ignite git commit: # sprint-2 Invalid assert, send can fail with ClusterTopologyCheckedException before discovery is notified
Date Thu, 26 Mar 2015 04:08:25 GMT
# 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 <sboikov@gridgain.com>
Authored: Wed Mar 25 12:23:28 2015 +0300
Committer: sboikov <sboikov@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);
 


Mime
View raw message