Added test for rebalance after restart.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/6f7011aa Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/6f7011aa Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/6f7011aa Branch: refs/heads/ignite-6181-1 Commit: 6f7011aa9c69280c76e03335ce4851a38cfc334e Parents: 316312d Author: sboikov <sboi...@gridgain.com> Authored: Fri Aug 25 16:59:02 2017 +0300 Committer: sboikov <sboi...@gridgain.com> Committed: Fri Aug 25 16:59:02 2017 +0300 ---------------------------------------------------------------------- .../IgnitePdsCacheRebalancingAbstractTest.java | 37 ++++++++++++++++++++ 1 file changed, 37 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/6f7011aa/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/IgnitePdsCacheRebalancingAbstractTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/IgnitePdsCacheRebalancingAbstractTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/IgnitePdsCacheRebalancingAbstractTest.java index 2f43951..91838fc 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/IgnitePdsCacheRebalancingAbstractTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/IgnitePdsCacheRebalancingAbstractTest.java @@ -498,6 +498,43 @@ public abstract class IgnitePdsCacheRebalancingAbstractTest extends GridCommonAb } /** + * @throws Exception If failed. + */ + public void testForceRebalance() throws Exception { + final Ignite ig = startGrids(4); + + ig.active(true); + + awaitPartitionMapExchange(); + + IgniteCache<Object, Object> c = ig.cache(cacheName); + + Integer val = 0; + + for (int i = 0; i < 5; i++) { + Integer key = primaryKey(ignite(3).cache(cacheName)); + + c.put(key, val); + + stopGrid(3); + + val++; + + c.put(key, val); + + assertEquals(val, c.get(key)); + + startGrid(3); + + awaitPartitionMapExchange(); + + Object val0 = ignite(3).cache(cacheName).get(key); + + assertEquals(val, val0); + } + } + + /** * @throws Exception If failed */ public void testPartitionCounterConsistencyOnUnstableTopology() throws Exception {
