[ignite] branch master updated: IGNITE-13561 Fix flaky test by waiting for partition eviction. - Fixes #8356.

[alexpl]

This is an automated email from the ASF dual-hosted git repository.

alexpl 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 9ca8049  IGNITE-13561 Fix flaky test by waiting for partition 
eviction. - Fixes #8356.
9ca8049 is described below

commit 9ca80493ea15cd2d6a677782d86fbb582690ef5f
Author: Ivan Daschinskiy <ivanda...@gmail.com>
AuthorDate: Wed Oct 14 18:12:40 2020 +0300

    IGNITE-13561 Fix flaky test by waiting for partition eviction. - Fixes 
#8356.
    
    Signed-off-by: Aleksey Plekhanov <plehanov.a...@gmail.com>
---
 .../cache/index/DynamicEnableIndexingConcurrentSelfTest.java     | 9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

diff --git 
a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/index/DynamicEnableIndexingConcurrentSelfTest.java
 
b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/index/DynamicEnableIndexingConcurrentSelfTest.java
index bdaa1ba..e28aed9 100644
--- 
a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/index/DynamicEnableIndexingConcurrentSelfTest.java
+++ 
b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/index/DynamicEnableIndexingConcurrentSelfTest.java
@@ -226,7 +226,8 @@ public class DynamicEnableIndexingConcurrentSelfTest 
extends DynamicEnableIndexi
         ignitionStart(serverConfiguration(2), finishLatch);
         ignitionStart(serverConfiguration(3), finishLatch);
 
-        awaitPartitionMapExchange();
+        // TODO: https://issues.apache.org/jira/browse/IGNITE-13572
+        awaitPartitionMapExchange(true, true, null);
 
         assertFalse(tblFut.isDone());
 
@@ -331,7 +332,8 @@ public class DynamicEnableIndexingConcurrentSelfTest 
extends DynamicEnableIndexi
 
         ignitionStart(serverConfiguration(4));
 
-        awaitPartitionMapExchange();
+        // TODO: https://issues.apache.org/jira/browse/IGNITE-13572
+        awaitPartitionMapExchange(true, true, null);
 
         tblFut.get();
 
@@ -493,7 +495,8 @@ public class DynamicEnableIndexingConcurrentSelfTest 
extends DynamicEnableIndexi
         // Check that only one successful attempt.
         assertEquals(1, success.get());
 
-        awaitPartitionMapExchange();
+        // TODO: https://issues.apache.org/jira/browse/IGNITE-13572
+        awaitPartitionMapExchange(true, true, null);
 
         for (Ignite g: G.allGrids()) {
             assertEquals(LARGE_NUM_ENTRIES, query(g, SELECT_ALL_QUERY).size());