You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by il...@apache.org on 2019/05/22 10:08:25 UTC
[ignite] branch master updated: IGNITE-11757 Fix test that shown
missed partitions during rebalancing - Fixes #6560.
This is an automated email from the ASF dual-hosted git repository.
ilyak pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git
The following commit(s) were added to refs/heads/master by this push:
new b87bea8 IGNITE-11757 Fix test that shown missed partitions during rebalancing - Fixes #6560.
b87bea8 is described below
commit b87bea845565394dd051a42cc097acd881cff1cf
Author: Vladislav Pyatkov <vl...@gmail.com>
AuthorDate: Wed May 22 13:07:38 2019 +0300
IGNITE-11757 Fix test that shown missed partitions during rebalancing - Fixes #6560.
Signed-off-by: Ilya Kasnacheev <il...@gmail.com>
---
.../distributed/dht/GridCachePartitionedSupplyEventsSelfTest.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridCachePartitionedSupplyEventsSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridCachePartitionedSupplyEventsSelfTest.java
index 0d974fa..84fe7be 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridCachePartitionedSupplyEventsSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridCachePartitionedSupplyEventsSelfTest.java
@@ -82,8 +82,7 @@ public class GridCachePartitionedSupplyEventsSelfTest extends GridCommonAbstract
lsnrs.put(new IgnitePredicate<CacheRebalancingEvent>() {
@Override public boolean apply(CacheRebalancingEvent evt) {
- //fail("Should not miss any partitions!");
- log.warning("Missed partition " + evt.partition() + " from node " + evt.node().consistentId());
+ fail("Should not miss any partitions!");
assertEquals(DEFAULT_CACHE_NAME, evt.cacheName());
@@ -128,6 +127,8 @@ public class GridCachePartitionedSupplyEventsSelfTest extends GridCommonAbstract
startGrid("g" + n);
+ awaitPartitionMapExchange();
+
int max = 0;
int min = PARTS;
int total = 0;