From c9f95cecdf2739f8c0f80a92e2c3a8d05e21498f Mon Sep 17 00:00:00 2001 From: chesnokoff Date: Tue, 3 Feb 2026 18:55:31 +0300 Subject: [PATCH] IGNITE-27708 Update ClientImpl#sendJoinRequest --- .../java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java index 151c0857ce433..9e1714867d2d2 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java @@ -728,6 +728,8 @@ private static void sleepEx(long millis, Runnable before, Runnable after) throws sock = spi.openSocket(addr, timeoutHelper); + openSock = true; + TcpDiscoveryIoSession ses = createSession(sock); TcpDiscoveryHandshakeRequest req = new TcpDiscoveryHandshakeRequest(locNodeId); @@ -745,6 +747,8 @@ private static void sleepEx(long millis, Runnable before, Runnable after) throws if (redirectAddrs != null) { U.closeQuiet(sock); + openSock = false; + if (log.isInfoEnabled()) log.info("Reconnecting to the addresses of a proper DC [addrs=" + redirectAddrs + ']');