This is an automated email from the ASF dual-hosted git repository. tkalkirill pushed a commit to branch ignite-27249 in repository https://gitbox.apache.org/repos/asf/ignite-3.git
commit e61fb5f85a6189617fd6e9e9623db7620cdcb391 Author: Kirill Tkalenko <[email protected]> AuthorDate: Thu Dec 4 13:59:38 2025 +0300 IGNITE-27249 wip --- .../org/apache/ignite/distributed/ItTxTestCluster.java | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) diff --git a/modules/table/src/testFixtures/java/org/apache/ignite/distributed/ItTxTestCluster.java b/modules/table/src/testFixtures/java/org/apache/ignite/distributed/ItTxTestCluster.java index cd726da0822..e1412e88f86 100644 --- a/modules/table/src/testFixtures/java/org/apache/ignite/distributed/ItTxTestCluster.java +++ b/modules/table/src/testFixtures/java/org/apache/ignite/distributed/ItTxTestCluster.java @@ -504,7 +504,7 @@ public class ItTxTestCluster { raftSrv, partitionRaftConfigurer, new VolatileLogStorageFactoryCreator(nodeName, workDir.resolve("volatile-log-spillout")), - Executors.newSingleThreadScheduledExecutor(), + executor, replicaGrpId -> nullCompletedFuture(), ForkJoinPool.commonPool() ); @@ -1201,14 +1201,6 @@ public class ItTxTestCluster { assertThat(client.stopAsync(new ComponentContext()), willCompleteSuccessfully()); } - if (executor != null) { - IgniteUtils.shutdownAndAwaitTermination(executor, 10, TimeUnit.SECONDS); - } - - if (partitionOperationsExecutor != null) { - IgniteUtils.shutdownAndAwaitTermination(partitionOperationsExecutor, 10, TimeUnit.SECONDS); - } - for (Entry<String, Loza> entry : raftServers.entrySet()) { Loza rs = entry.getValue(); @@ -1273,6 +1265,14 @@ public class ItTxTestCluster { assertThat(clockWaiter.stopAsync(new ComponentContext()), willCompleteSuccessfully()); } } + + if (executor != null) { + IgniteUtils.shutdownAndAwaitTermination(executor, 10, TimeUnit.SECONDS); + } + + if (partitionOperationsExecutor != null) { + IgniteUtils.shutdownAndAwaitTermination(partitionOperationsExecutor, 10, TimeUnit.SECONDS); + } } /**
