This is an automated email from the ASF dual-hosted git repository.
zstan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git
The following commit(s) were added to refs/heads/master by this push:
new 79bb4654278 IGNITE-28573 Fix flaky TcpDiscoveryIpFinderFailureTest
(#13047)
79bb4654278 is described below
commit 79bb4654278b8b944826799c908a0409d4c9c581
Author: Dmitry Werner <[email protected]>
AuthorDate: Mon Apr 20 16:44:05 2026 +0500
IGNITE-28573 Fix flaky TcpDiscoveryIpFinderFailureTest (#13047)
---
.../ignite/spi/discovery/tcp/TcpDiscoveryIpFinderFailureTest.java | 8 ++++++--
1 file changed, 6 insertions(+), 2 deletions(-)
diff --git
a/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoveryIpFinderFailureTest.java
b/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoveryIpFinderFailureTest.java
index 3a4e168ab58..d776f5e9e68 100644
---
a/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoveryIpFinderFailureTest.java
+++
b/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoveryIpFinderFailureTest.java
@@ -85,6 +85,7 @@ public class TcpDiscoveryIpFinderFailureTest extends
GridCommonAbstractTest {
public void testClientNodeStaticIpFinderFailure() throws Exception {
dynamicIpFinder.setAddresses(Collections.singleton("127.0.0.1:47500"));
dynamicIpFinder.setShared(false);
+
runClientNodeIpFinderFailureTest(TcpDiscoverySpi.DFLT_RECONNECT_DELAY);
}
@@ -116,9 +117,11 @@ public class TcpDiscoveryIpFinderFailureTest extends
GridCommonAbstractTest {
IgniteConfiguration cfgSrv = getConfigurationDynamicIpFinder("Server",
false);
+ long netTimeout = 4000;
+
TcpDiscoverySpi discoverySpi = new TcpDiscoverySpi();
discoverySpi.setJoinTimeout(10000);
- discoverySpi.setNetworkTimeout(4000);
+ discoverySpi.setNetworkTimeout(netTimeout);
discoverySpi.setReconnectDelay((int)reconnectDelay);
discoverySpi.setIpFinder(dynamicIpFinder);
@@ -143,7 +146,8 @@ public class TcpDiscoveryIpFinderFailureTest extends
GridCommonAbstractTest {
return true;
}, EVT_CLIENT_NODE_DISCONNECTED);
- assertTrue("Failed to wait for client node disconnected.",
latch.await(6, SECONDS));
+ assertTrue("Failed to wait for client node disconnected.",
+ latch.await(2 * Math.max(reconnectDelay, netTimeout) / 1000,
SECONDS));
}
/**