(ignite) branch master updated: IGNITE-25695 SQL Calcite: Fix flaky TimeCalculationExecutionTest (#12146)

[alexpl]

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 4ec0626cba1 IGNITE-25695 SQL Calcite: Fix flaky 
TimeCalculationExecutionTest (#12146)
4ec0626cba1 is described below

commit 4ec0626cba159a05fa0f97685a3ec50dbe620dfd
Author: Aleksey Plekhanov <plehanov.a...@gmail.com>
AuthorDate: Fri Jul 25 09:14:50 2025 +0300

    IGNITE-25695 SQL Calcite: Fix flaky TimeCalculationExecutionTest (#12146)
---
 .../query/calcite/exec/rel/AbstractExecutionTest.java          | 10 +++++++++-
 .../query/calcite/exec/rel/TimeCalculationExecutionTest.java   |  2 +-
 2 files changed, 10 insertions(+), 2 deletions(-)

diff --git 
a/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/AbstractExecutionTest.java
 
b/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/AbstractExecutionTest.java
index de24b8de4d0..b38043b404b 100644
--- 
a/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/AbstractExecutionTest.java
+++ 
b/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/AbstractExecutionTest.java
@@ -210,7 +210,15 @@ public class AbstractExecutionTest extends 
GridCommonAbstractTest {
                 taskExecutor = executor;
             }
             else {
-                taskExecutor = new QueryBlockingTaskExecutor(kernal);
+                taskExecutor = new QueryBlockingTaskExecutor(kernal) {
+                    @Override public void execute(UUID qryId, long fragmentId, 
Runnable qryTask) {
+                        super.execute(qryId, fragmentId, () -> {
+                            qryTask.run();
+
+                            
LockSupport.parkNanos(ThreadLocalRandom.current().nextLong(1_000, 10_000));
+                        });
+                    }
+                };
 
                 taskExecutor.onStart(kernal);
             }
diff --git 
a/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/TimeCalculationExecutionTest.java
 
b/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/TimeCalculationExecutionTest.java
index 91b8a760270..e13b1a5a177 100644
--- 
a/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/TimeCalculationExecutionTest.java
+++ 
b/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/TimeCalculationExecutionTest.java
@@ -59,7 +59,7 @@ public class TimeCalculationExecutionTest extends 
AbstractExecutionTest {
 
         rootNode.hasNext();
 
-        srcNode.latch.await(1_000L, TimeUnit.MILLISECONDS);
+        assertTrue(srcNode.latch.await(1_000L, TimeUnit.MILLISECONDS));
 
         long execTime0 = rootNode.execTime();
         long idleTime0 = rootNode.idleTime();