You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ir...@apache.org on 2020/02/03 11:50:05 UTC

[ignite] branch master updated: IGNITE-12607 PartitionsExchangeAwareTest is flaky - Fixes #7339.

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

irakov 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 7beefee  IGNITE-12607 PartitionsExchangeAwareTest is flaky - Fixes #7339.
7beefee is described below

commit 7beefeebc775ec63e56f2dd7ec8f6640cdc099d3
Author: Ivan Rakov <ir...@apache.org>
AuthorDate: Mon Feb 3 14:49:34 2020 +0300

    IGNITE-12607 PartitionsExchangeAwareTest is flaky - Fixes #7339.
---
 .../cache/distributed/PartitionsExchangeAwareTest.java         | 10 +++++++---
 1 file changed, 7 insertions(+), 3 deletions(-)

diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/PartitionsExchangeAwareTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/PartitionsExchangeAwareTest.java
index 2070dcd..48512f0 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/PartitionsExchangeAwareTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/PartitionsExchangeAwareTest.java
@@ -263,10 +263,14 @@ public class PartitionsExchangeAwareTest extends GridCommonAbstractTest {
 
         assertEquals(updatePossible, GridTestUtils.waitForCondition(new GridAbsPredicate() {
             @Override public boolean apply() {
-                assertTrue(txUpdateFut.isDone() == atomicUpdateFut.isDone());
-
-                return atomicUpdateFut.isDone();
+                return atomicUpdateFut.isDone() && txUpdateFut.isDone();
             }
         }, TIMEOUT_SECONDS * 1000));
+
+        if (!updatePossible) {
+            assertFalse(atomicUpdateFut.isDone());
+
+            assertFalse(txUpdateFut.isDone());
+        }
     }
 }