ignite-12163 remove testNoRebalancingOnRestartDeactivated as deprecated
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/6ec62bb5 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/6ec62bb5 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/6ec62bb5 Branch: refs/heads/ignite-5075-pds Commit: 6ec62bb56991df0c77d72e3a507b8bbb1567e316 Parents: f90cae2 Author: Dmitriy Govorukhin <[email protected]> Authored: Thu May 18 21:29:22 2017 +0300 Committer: Dmitriy Govorukhin <[email protected]> Committed: Thu May 18 21:29:22 2017 +0300 ---------------------------------------------------------------------- ...istentStoreCacheRebalancingAbstractTest.java | 69 -------------------- 1 file changed, 69 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/6ec62bb5/modules/pds/src/test/java/org/apache/ignite/cache/database/IgnitePersistentStoreCacheRebalancingAbstractTest.java ---------------------------------------------------------------------- diff --git a/modules/pds/src/test/java/org/apache/ignite/cache/database/IgnitePersistentStoreCacheRebalancingAbstractTest.java b/modules/pds/src/test/java/org/apache/ignite/cache/database/IgnitePersistentStoreCacheRebalancingAbstractTest.java index 4d33d22..663fe5b 100644 --- a/modules/pds/src/test/java/org/apache/ignite/cache/database/IgnitePersistentStoreCacheRebalancingAbstractTest.java +++ b/modules/pds/src/test/java/org/apache/ignite/cache/database/IgnitePersistentStoreCacheRebalancingAbstractTest.java @@ -274,75 +274,6 @@ public abstract class IgnitePersistentStoreCacheRebalancingAbstractTest extends } /** - * Test that up-to-date partitions aren't rebalanced after cluster restarts gracefully. - * - * @throws Exception If fails. - */ - public void testNoRebalancingOnRestartDeactivated() throws Exception { - fail(); - IgniteEx ignite1 = (IgniteEx)G.start(getConfiguration("test1")); - IgniteEx ignite2 = (IgniteEx)G.start(getConfiguration("test2")); - IgniteEx ignite3 = (IgniteEx)G.start(getConfiguration("test3")); - IgniteEx ignite4 = (IgniteEx)G.start(getConfiguration("test4")); - - awaitPartitionMapExchange(); - - IgniteCache<Integer, Integer> cache1 = ignite1.cache(cacheName); - - final Collection<Integer> parts = new HashSet<>(); - - for (int i = 0; i < 100; i++) { - cache1.put(i, i); - parts.add(ignite1.affinity(cacheName).partition(i)); - } - - ignite1.active(false); - - ignite1.close(); - ignite2.close(); - ignite3.close(); - ignite4.close(); - - final AtomicInteger evtCnt = new AtomicInteger(); - - ignite1 = (IgniteEx)G.start(getConfiguration("test1")); - - cache1 = ignite1.cache(cacheName); - - ignite1.active(false); - - ignite1.events().remoteListen(new IgniteBiPredicate<UUID, CacheRebalancingEvent>() { - @Override public boolean apply(UUID uuid, CacheRebalancingEvent evt) { - if (Objects.equals(evt.cacheName(), cacheName) && parts.contains(evt.partition())) - evtCnt.incrementAndGet(); - - return true; - } - }, null, EventType.EVT_CACHE_REBALANCE_PART_LOADED); - - ignite2 = (IgniteEx)G.start(getConfiguration("test2")); - ignite3 = (IgniteEx)G.start(getConfiguration("test3")); - ignite4 = (IgniteEx)G.start(getConfiguration("test4")); - - ignite1.active(true); - - awaitPartitionMapExchange(); - - assert evtCnt.get() == 0 : evtCnt.get(); - - IgniteCache<Integer, Integer> cache2 = ignite2.cache(cacheName); - IgniteCache<Integer, Integer> cache3 = ignite3.cache(cacheName); - IgniteCache<Integer, Integer> cache4 = ignite4.cache(cacheName); - - for (int i = 0; i < 100; i++) { - assert cache1.get(i).equals(i); - assert cache2.get(i).equals(i); - assert cache3.get(i).equals(i); - assert cache4.get(i).equals(i); - } - } - - /** * Test that all data is correctly restored after non-graceful restart. * * @throws Exception If fails.
