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);