This is an automated email from the ASF dual-hosted git repository. ppa pushed a commit to branch ignite-28084 in repository https://gitbox.apache.org/repos/asf/ignite-3.git
commit ade84d9da4b4d006996f0d7fe5ecc4fc5b5a8dc2 Author: Pavel Pereslegin <[email protected]> AuthorDate: Fri Mar 6 09:35:30 2026 +0300 IGNITE-28084 Fix flaky test ExecutionServiceImplTest.outdatedNodeLeftEventDoesntCauseQueryToHang. --- .../sql/engine/exec/ExecutionServiceImplTest.java | 16 ++++++++++++---- 1 file changed, 12 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..34726d89212 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,19 @@ 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 executer", e); + } + }); + + executers.forEach(threadPool -> { + try { + threadPool.stop(); + } catch (Exception e) { + log.error("Unable to stop thread pool", e); } }); @@ -1529,7 +1537,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} */
