diff --git a/enterprise/causal-clustering/src/main/java/org/neo4j/causalclustering/discovery/HazelcastCoreTopologyService.java b/enterprise/causal-clustering/src/main/java/org/neo4j/causalclustering/discovery/HazelcastCoreTopologyService.java index 993e7c820a182..b0650684d069b 100644 --- a/enterprise/causal-clustering/src/main/java/org/neo4j/causalclustering/discovery/HazelcastCoreTopologyService.java +++ b/enterprise/causal-clustering/src/main/java/org/neo4j/causalclustering/discovery/HazelcastCoreTopologyService.java @@ -159,7 +159,6 @@ private HazelcastInstance createHazelcastInstance() { tcpIpConfig.addMember( address.toString() ); } - log.info( "Discovering cluster with initial members: " + initialMembers ); Setting discovery_listen_address = CausalClusteringSettings.discovery_listen_address; ListenSocketAddress hazelcastAddress = config.get( discovery_listen_address ); @@ -185,7 +184,7 @@ private HazelcastInstance createHazelcastInstance() MemberAttributeConfig memberAttributeConfig = HazelcastClusterTopology.buildMemberAttributes( myself, config ); c.setMemberAttributeConfig( memberAttributeConfig ); - userLog.info( "Waiting for other members to join cluster before continuing..." ); + logConnectionInfo( initialMembers ); DelayedLog delayedLog = new DelayedLog( "The server has not been able to connect in a timely fashion to the " + "cluster. Please consult the logs for more details. Rebooting the server may solve the problem", log ); @@ -212,6 +211,25 @@ private HazelcastInstance createHazelcastInstance() return hazelcastInstance; } + private void logConnectionInfo( List initialMembers ) + { + userLog.info( "My connection info: " + + "[\n\tDiscovery: listen=%s, advertised=%s," + + "\n\tTransaction: listen=%s, advertised=%s, " + + "\n\tRaft: listen=%s, advertised=%s, " + + "\n\tClient Connector Addresses: %s" + + "\n]", + config.get( CausalClusteringSettings.discovery_listen_address ), + config.get( CausalClusteringSettings.discovery_advertised_address ), + config.get( CausalClusteringSettings.transaction_listen_address ), + config.get( CausalClusteringSettings.transaction_advertised_address ), + config.get( CausalClusteringSettings.raft_listen_address ), + config.get( CausalClusteringSettings.raft_advertised_address ), + ClientConnectorAddresses.extractFromConfig( config ) ); + userLog.info( "Discovering cluster with initial members: " + initialMembers ); + userLog.info( "Attempting to connect to the other cluster members before continuing..." ); + } + private Integer minimumClusterSizeThatCanTolerateOneFaultForExpectedClusterSize() { return config.get( CausalClusteringSettings.expected_core_cluster_size ) / 2 + 1;