(ignite-3) branch main updated: IGNITE-27905 Fix flaky tests in jraft module connected to unstable network. (#7876)

[apolovtsev]

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 da74e17d758 IGNITE-27905 Fix flaky tests in jraft module connected to 
unstable network. (#7876)
da74e17d758 is described below

commit da74e17d7584a7fbe824158c67cd8d8dc3cf86de
Author: Mirza Aliev <alievmi...@gmail.com>
AuthorDate: Thu Mar 26 18:57:05 2026 +0400

    IGNITE-27905 Fix flaky tests in jraft module connected to unstable network. 
(#7876)
---
 .../java/org/apache/ignite/raft/jraft/core/TestCluster.java    | 10 ++++------
 1 file changed, 4 insertions(+), 6 deletions(-)

diff --git 
a/modules/raft/src/integrationTest/java/org/apache/ignite/raft/jraft/core/TestCluster.java
 
b/modules/raft/src/integrationTest/java/org/apache/ignite/raft/jraft/core/TestCluster.java
index db0a3a77b78..78775c99da8 100644
--- 
a/modules/raft/src/integrationTest/java/org/apache/ignite/raft/jraft/core/TestCluster.java
+++ 
b/modules/raft/src/integrationTest/java/org/apache/ignite/raft/jraft/core/TestCluster.java
@@ -250,19 +250,17 @@ public class TestCluster {
 
             nodeOptions.setRaftGrpEvtsLsnr(raftGrpEvtsLsnr);
 
-            List<NetworkAddress> addressList = List.of();
-
             if (!emptyPeers) {
-                addressList = Stream.concat(peers.stream(), learners.stream())
-                        .map(p -> new 
NetworkAddress(TestUtils.getLocalAddress(), p.getPort()))
-                        .collect(toList());
-
                 nodeOptions.setInitialConf(new Configuration(
                         
peers.stream().map(TestPeer::getPeerId).collect(toList()),
                         getLearners()
                 ));
             }
 
+            List<NetworkAddress> addressList = Stream.concat(peers.stream(), 
learners.stream())
+                    .map(p -> new NetworkAddress(TestUtils.getLocalAddress(), 
p.getPort()))
+                    .collect(toList());
+
             ClusterService clusterService = clusterService(testInfo, 
peer.getPort(), new StaticNodeFinder(addressList));
             NodeManager nodeManager = new NodeManager(clusterService);