diff --git a/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/integration/AbstractBasicIntegrationTest.java b/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/integration/AbstractBasicIntegrationTest.java
index 31eed86a2efae..3e4534100605d 100644
--- a/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/integration/AbstractBasicIntegrationTest.java
+++ b/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/integration/AbstractBasicIntegrationTest.java
@@ -109,8 +109,8 @@ protected boolean destroyCachesAfterTest() {
 
             CalciteQueryProcessor qryProc = queryProcessor(ign);
 
-            assertEquals("Not finished queries found [ignite=" + ign.name() + ']',
-                0, qryProc.queryRegistry().runningQueries().size());
+            assertTrue("Not finished queries found [ignite=" + ign.name() + ']',
+                waitForCondition(() -> qryProc.queryRegistry().runningQueries().isEmpty(), 1_000));
 
             ExecutionServiceImpl<Object[]> execSvc = (ExecutionServiceImpl<Object[]>)qryProc.executionService();
             assertEquals("Tracked memory must be 0 after test [ignite=" + ign.name() + ']',