[ignite] branch master updated: IGNITE-12925: Fix flaky tests for continuous query metrics. (#7747)

[mmuzaf]

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

mmuzaf 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 50776f5  IGNITE-12925: Fix flaky tests for continuous query metrics. 
(#7747)
50776f5 is described below

commit 50776f58a14486f5e2e8d2052515b4557a99453a
Author: Mikhail Petrov <32207922+ololo3...@users.noreply.github.com>
AuthorDate: Wed Apr 29 15:22:08 2020 +0300

    IGNITE-12925: Fix flaky tests for continuous query metrics. (#7747)
---
 .../java/org/apache/ignite/internal/metric/JmxExporterSpiTest.java     | 2 +-
 .../java/org/apache/ignite/internal/metric/SystemViewSelfTest.java     | 2 +-
 .../internal/processors/cache/metric/SqlViewExporterSpiTest.java       | 3 ++-
 3 files changed, 4 insertions(+), 3 deletions(-)

diff --git 
a/modules/core/src/test/java/org/apache/ignite/internal/metric/JmxExporterSpiTest.java
 
b/modules/core/src/test/java/org/apache/ignite/internal/metric/JmxExporterSpiTest.java
index 6377ea2..b6d835c 100644
--- 
a/modules/core/src/test/java/org/apache/ignite/internal/metric/JmxExporterSpiTest.java
+++ 
b/modules/core/src/test/java/org/apache/ignite/internal/metric/JmxExporterSpiTest.java
@@ -422,7 +422,7 @@ public class JmxExporterSpiTest extends 
AbstractExporterSpiTest {
             }
 
             assertEquals(0, systemView(CQ_SYS_VIEW).size());
-            assertEquals(0, systemView(remoteNode, CQ_SYS_VIEW).size());
+            assertTrue(waitForCondition(() -> systemView(remoteNode, 
CQ_SYS_VIEW).isEmpty(), getTestTimeout()));
         }
     }
 
diff --git 
a/modules/core/src/test/java/org/apache/ignite/internal/metric/SystemViewSelfTest.java
 
b/modules/core/src/test/java/org/apache/ignite/internal/metric/SystemViewSelfTest.java
index af0cd71..19bdce5 100644
--- 
a/modules/core/src/test/java/org/apache/ignite/internal/metric/SystemViewSelfTest.java
+++ 
b/modules/core/src/test/java/org/apache/ignite/internal/metric/SystemViewSelfTest.java
@@ -526,7 +526,7 @@ public class SystemViewSelfTest extends 
GridCommonAbstractTest {
             }
 
             assertEquals(0, origQrys.size());
-            assertEquals(0, remoteQrys.size());
+            assertTrue(waitForCondition(() -> remoteQrys.size() == 0, 
getTestTimeout()));
         }
     }
 
diff --git 
a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/metric/SqlViewExporterSpiTest.java
 
b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/metric/SqlViewExporterSpiTest.java
index ae33dbe..0f54e30 100644
--- 
a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/metric/SqlViewExporterSpiTest.java
+++ 
b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/metric/SqlViewExporterSpiTest.java
@@ -560,7 +560,8 @@ public class SqlViewExporterSpiTest extends 
AbstractExporterSpiTest {
         }
 
         assertTrue(execute(ignite0, "SELECT * FROM 
SYS.CONTINUOUS_QUERIES").isEmpty());
-        assertTrue(execute(ignite1, "SELECT * FROM 
SYS.CONTINUOUS_QUERIES").isEmpty());
+        assertTrue(waitForCondition(() ->
+            execute(ignite1, "SELECT * FROM 
SYS.CONTINUOUS_QUERIES").isEmpty(), getTestTimeout()));
     }
 
     /** */