From 14912bb88ea05fc3a9582c1d99a6026d02762f31 Mon Sep 17 00:00:00 2001
From: zstan <zstan@apache.org>
Date: Thu, 29 Jan 2026 12:38:08 +0300
Subject: [PATCH] IGNITE-27695 Calcite. TpchScale001Test can fail due to race
 between query close check

---
 .../calcite/integration/AbstractBasicIntegrationTest.java     | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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() + ']',