(ignite-3) branch main updated: IGNITE-28084 Sql. Fix flaky test ExecutionServiceImplTest.outdatedNodeLeftEventDoesntCauseQueryToHang (#7720)

[ppa]

This is an automated email from the ASF dual-hosted git repository.

ppa pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git


The following commit(s) were added to refs/heads/main by this push:
     new 810bd397db9 IGNITE-28084 Sql. Fix flaky test 
ExecutionServiceImplTest.outdatedNodeLeftEventDoesntCauseQueryToHang (#7720)
810bd397db9 is described below

commit 810bd397db9f200b502c014bb5a51c26092a7876
Author: Pavel Pereslegin <xxt...@gmail.com>
AuthorDate: Fri Mar 6 12:51:49 2026 +0300

    IGNITE-28084 Sql. Fix flaky test 
ExecutionServiceImplTest.outdatedNodeLeftEventDoesntCauseQueryToHang (#7720)
---
 .../sql/engine/exec/ExecutionServiceImplTest.java    | 20 ++++++++++++++++----
 1 file changed, 16 insertions(+), 4 deletions(-)

diff --git 
a/modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/ExecutionServiceImplTest.java
 
b/modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/ExecutionServiceImplTest.java
index 7e367802eb1..eafc0860c13 100644
--- 
a/modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/ExecutionServiceImplTest.java
+++ 
b/modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/ExecutionServiceImplTest.java
@@ -321,11 +321,23 @@ public class ExecutionServiceImplTest extends 
BaseIgniteAbstractTest {
 
         mailboxes.clear();
 
-        executionServices.forEach(executer -> {
+        executionServices.forEach(executionService -> {
             try {
-                executer.stop();
+                executionService.stop();
             } catch (Exception e) {
-                log.error("Unable to stop executor", e);
+                log.error("Unable to stop execution service", e);
+            }
+        });
+
+        executers.forEach(threadPool -> {
+            try {
+                if (threadPool instanceof QueryTaskExecutorImpl) {
+                    Awaitility.await().until(() -> ((QueryTaskExecutorImpl) 
threadPool).queueSize(), is(0));
+                }
+
+                threadPool.stop();
+            } catch (Exception e) {
+                log.error("Unable to stop thread pool", e);
             }
         });
 
@@ -1529,7 +1541,7 @@ public class ExecutionServiceImplTest extends 
BaseIgniteAbstractTest {
                     public CompletableFuture<Void> send(String nodeName, 
NetworkMessage msg) {
                         TestNode node = nodes.get(nodeName);
 
-                        return runAsync(() -> {}).thenCompose(none -> 
node.onReceive(TestNode.this.node, msg));
+                        return runAsync(() -> 
await(node.onReceive(TestNode.this.node, msg)));
                     }
 
                     /** {@inheritDoc} */