You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by nt...@apache.org on 2015/11/09 18:49:28 UTC
[3/3] ignite git commit: IGNITE-462 Fixed tests.
IGNITE-462 Fixed tests.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/b749b3d7
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/b749b3d7
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/b749b3d7
Branch: refs/heads/ignite-426-2
Commit: b749b3d7a8359ede13650a359b4cb969304f6e2a
Parents: aa22202
Author: Tikhonov Nikolay <ti...@gmail.com>
Authored: Mon Nov 9 20:52:28 2015 +0300
Committer: Tikhonov Nikolay <ti...@gmail.com>
Committed: Mon Nov 9 20:52:28 2015 +0300
----------------------------------------------------------------------
.../cache/distributed/dht/GridDhtPartitionTopologyImpl.java | 2 +-
.../CacheContinuousQueryFailoverAbstractSelfTest.java | 9 ---------
.../GridCacheContinuousQueryAbstractSelfTest.java | 6 ------
3 files changed, 1 insertion(+), 16 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/b749b3d7/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtPartitionTopologyImpl.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtPartitionTopologyImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtPartitionTopologyImpl.java
index b835df2..39c55db 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtPartitionTopologyImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtPartitionTopologyImpl.java
@@ -1355,7 +1355,7 @@ class GridDhtPartitionTopologyImpl implements GridDhtPartitionTopology {
List<ClusterNode> affNodes = cctx.affinity().nodes(i, topVer);
// Topology doesn't contain server nodes (just clients).
- if (affNodes.isEmpty())
+ if (affNodes.isEmpty() || (node2part != null && !node2part.valid()))
continue;
List<ClusterNode> owners = owners(i);
http://git-wip-us.apache.org/repos/asf/ignite/blob/b749b3d7/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryFailoverAbstractSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryFailoverAbstractSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryFailoverAbstractSelfTest.java
index e82c673..b311272 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryFailoverAbstractSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryFailoverAbstractSelfTest.java
@@ -271,15 +271,6 @@ public abstract class CacheContinuousQueryFailoverAbstractSelfTest extends GridC
waitRebalanceFinished(ignite0, 5);
waitRebalanceFinished(ignite2, 5);
waitRebalanceFinished(ignite3, 5);
-
- stopGrid(3);
-
- assertTrue(top0.rebalanceFinished(new AffinityTopologyVersion(6)));
- assertTrue(top2.rebalanceFinished(new AffinityTopologyVersion(6)));
-
- stopGrid(0);
-
- waitRebalanceFinished(ignite2, 7);
}
/**
http://git-wip-us.apache.org/repos/asf/ignite/blob/b749b3d7/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/GridCacheContinuousQueryAbstractSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/GridCacheContinuousQueryAbstractSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/GridCacheContinuousQueryAbstractSelfTest.java
index 251cbe2..f7a080a 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/GridCacheContinuousQueryAbstractSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/GridCacheContinuousQueryAbstractSelfTest.java
@@ -193,12 +193,6 @@ public abstract class GridCacheContinuousQueryAbstractSelfTest extends GridCommo
}
}
- for (int i = 0; i < gridCount(); i++)
- assertEquals("Cache is not empty [entrySet=" + grid(i).cache(null).localEntries() +
- ", i=" + i + ']',
- 0, grid(i).cache(null).localSize());
-
-
for (int i = 0; i < gridCount(); i++) {
GridContinuousProcessor proc = grid(i).context().continuous();