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 794382dee52e8..208e2c074ab02 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 @@ -2330,12 +2330,12 @@ private void processNodeAddFinishedMessage(TcpDiscoveryNodeAddFinishedMessage ms Collection nodes = updateTopologyHistory(topVer, msg); - notifyDiscovery(EVT_NODE_JOINED, topVer, locNode, nodes, msg.spanContainer()); - boolean disconnected = disconnected(); state = CONNECTED; + notifyDiscovery(EVT_NODE_JOINED, topVer, locNode, nodes, msg.spanContainer()); + if (disconnected) { notifyDiscovery(EVT_CLIENT_NODE_RECONNECTED, topVer, locNode, nodes, null);