WIP

Author: anton-vinogradov

modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java

@@ -633,6 +633,7 @@ else if (addrs.isEmpty()) {
         }
     }
 
+    /** */
     private T2<Boolean, T3<SocketStream, Integer, Boolean>> sendJoinRequests(
         boolean recon,
         Collection<InetSocketAddress> addrs

modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java

@@ -6848,17 +6848,17 @@ else if (log.isDebugEnabled())
                         res.clientAck(true);
 
                         if (req.dcId() != null && !Objects.equals(req.dcId(), locNode.dataCenterId())) {
-                                Optional<TcpDiscoveryNode> dcNode = ring.serverNodes().stream()
-                                    .filter(node -> node.dataCenterId() != null && node.dataCenterId().equals(req.dcId()))
-                                    .findAny();
+                            Optional<TcpDiscoveryNode> dcNode = ring.serverNodes().stream()
+                                .filter(node -> node.dataCenterId() != null && node.dataCenterId().equals(req.dcId()))
+                                .findAny();
 
-                                if (dcNode.isPresent()) {
-                                    res.redirectAddresses(dcNode.get().socketAddresses());
+                            if (dcNode.isPresent()) {
+                                res.redirectAddresses(dcNode.get().socketAddresses());
 
-                                    spi.writeToSocket(sock, spi.socketStream(sock), res, spi.getEffectiveSocketTimeout(srvSock));
+                                spi.writeToSocket(sock, spi.socketStream(sock), res, spi.getEffectiveSocketTimeout(srvSock));
 
-                                    return;
-                                }
+                                return;
+                            }
                         }
                     }
                     else if (req.changeTopology()) {