This is an automated email from the ASF dual-hosted git repository.
apolovtsev 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 96a2160fd0 IGNITE-20776 Stop nodes in parallel on Cluster shutdown
(#2781)
96a2160fd0 is described below
commit 96a2160fd0717f90c947180083c287b2c8a6b276
Author: Roman Puchkovskiy <[email protected]>
AuthorDate: Wed Nov 1 19:41:08 2023 +0400
IGNITE-20776 Stop nodes in parallel on Cluster shutdown (#2781)
---
.../src/testFixtures/java/org/apache/ignite/internal/Cluster.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/modules/runner/src/testFixtures/java/org/apache/ignite/internal/Cluster.java
b/modules/runner/src/testFixtures/java/org/apache/ignite/internal/Cluster.java
index bd98e922c7..58a03e8987 100644
---
a/modules/runner/src/testFixtures/java/org/apache/ignite/internal/Cluster.java
+++
b/modules/runner/src/testFixtures/java/org/apache/ignite/internal/Cluster.java
@@ -455,7 +455,7 @@ public class Cluster {
nodesToStop = runningNodes().collect(toList());
}
- nodesToStop.forEach(node -> IgnitionManager.stop(node.name()));
+ nodesToStop.parallelStream().forEach(node ->
IgnitionManager.stop(node.name()));
}
/**
