Repository: ignite Updated Branches: refs/heads/ignite-3477-master 7eb1234cb -> d69a5942d
IGNITE-4534: Page eviction rebalance test fix. Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/2068a751 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/2068a751 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/2068a751 Branch: refs/heads/ignite-3477-master Commit: 2068a7510b09e193a33ae074b5161f1166399b7e Parents: 7eb1234 Author: Ivan Rakov <[email protected]> Authored: Tue Apr 11 15:24:02 2017 +0300 Committer: Ivan Rakov <[email protected]> Committed: Tue Apr 11 15:24:02 2017 +0300 ---------------------------------------------------------------------- .../cache/eviction/paged/PageEvictionWithRebalanceTest.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/2068a751/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/eviction/paged/PageEvictionWithRebalanceTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/eviction/paged/PageEvictionWithRebalanceTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/eviction/paged/PageEvictionWithRebalanceTest.java index fd80201..f174908 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/eviction/paged/PageEvictionWithRebalanceTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/eviction/paged/PageEvictionWithRebalanceTest.java @@ -51,11 +51,11 @@ public abstract class PageEvictionWithRebalanceTest extends PageEvictionAbstract System.out.println(">>> Entries put: " + i); } - int size = cache.size(CachePeekMode.PRIMARY); + int size = cache.size(CachePeekMode.ALL); System.out.println(">>> Resulting size: " + size); - assertTrue(size < ENTRIES); + assertTrue(size < ENTRIES * 2); // Primary entries and backups. for (int i = 3; i >= 1; i--) { stopGrid(i); @@ -64,7 +64,7 @@ public abstract class PageEvictionWithRebalanceTest extends PageEvictionAbstract awaitPartitionMapExchange(); - int rebalanceSize = cache.size(CachePeekMode.PRIMARY); + int rebalanceSize = cache.size(CachePeekMode.ALL); System.out.println(">>> Size after rebalance: " + rebalanceSize);
