ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [29/50] [abbrv] ignite git commit: ignite-12163 remove testNoRebalancingOnRestartDeactivated as deprecated
Date Mon, 22 May 2017 15:12:57 GMT
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 <dmitriy.govorukhin@gmail.com>
Authored: Thu May 18 21:29:22 2017 +0300
Committer: Dmitriy Govorukhin <dmitriy.govorukhin@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.


Mime
View raw message