You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2017/05/22 15:12:57 UTC
[29/50] [abbrv] ignite git commit: ignite-12163 remove
testNoRebalancingOnRestartDeactivated as deprecated
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 <dm...@gmail.com>
Authored: Thu May 18 21:29:22 2017 +0300
Committer: Dmitriy Govorukhin <dm...@gmail.com>
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.