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 fdac626e216 IGNITE-27755 SQL Calcite: Fix flaky 
SqlDiagnosticIntegrationTest - Fixes #12701.
fdac626e216 is described below

commit fdac626e21628e94dff08fef4df900f59f6bbe9e
Author: Aleksey Plekhanov <[email protected]>
AuthorDate: Thu Feb 12 16:29:00 2026 +0300

    IGNITE-27755 SQL Calcite: Fix flaky SqlDiagnosticIntegrationTest - Fixes 
#12701.
    
    Signed-off-by: Aleksey Plekhanov <[email protected]>
---
 .../calcite/integration/SqlDiagnosticIntegrationTest.java | 15 ++-------------
 1 file changed, 2 insertions(+), 13 deletions(-)

diff --git 
a/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/integration/SqlDiagnosticIntegrationTest.java
 
b/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/integration/SqlDiagnosticIntegrationTest.java
index 944c7785839..f468cc7ee69 100644
--- 
a/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/integration/SqlDiagnosticIntegrationTest.java
+++ 
b/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/integration/SqlDiagnosticIntegrationTest.java
@@ -1023,7 +1023,7 @@ public class SqlDiagnosticIntegrationTest extends 
AbstractBasicIntegrationTest {
 
         log.registerListener(logLsnr);
 
-        cache.query(new SqlFieldsQuery("SELECT 
sleep(?)").setArgs(LONG_QRY_TIMEOUT).setQueryInitiatorId(initiatorId))
+        cache.query(new SqlFieldsQuery("SELECT 
sleep(?)").setArgs(LONG_QRY_TIMEOUT + 1).setQueryInitiatorId(initiatorId))
             .getAll();
 
         assertTrue(logLsnr.check(1000));
@@ -1044,18 +1044,7 @@ public class SqlDiagnosticIntegrationTest extends 
AbstractBasicIntegrationTest {
         int sleepTime = 500;
 
         for (int i = 0; i < 2; i++) {
-            FunctionsLibrary.latch = new CountDownLatch(1);
-
-            IgniteInternalFuture<?> fut = GridTestUtils.runAsync(
-                () -> cache.query(new SqlFieldsQuery("select * from test where 
waitLatch(10000)")).getAll());
-
-            U.sleep(sleepTime);
-
-            GridTestClockTimer.update();
-
-            FunctionsLibrary.latch.countDown();
-
-            fut.get();
+            cache.query(new SqlFieldsQuery("SELECT 
sleep(?)").setArgs(sleepTime)).getAll();
 
             assertTrue(waitForCondition(() -> {
                 SystemView<SqlQueryHistoryView> history = 
grid.context().systemView().view(SQL_QRY_HIST_VIEW);

Reply via email to