SONAR-9802 fix support of overridden cluster name

server/sonar-main/src/main/java/org/sonar/application/AppStateFactory.java

@@ -49,7 +49,6 @@ public class AppStateFactory {
 
   private static HazelcastMember createHzMember(Props props) {
     HazelcastMemberBuilder builder = new HazelcastMemberBuilder()
-      .setClusterName("sonarqube")
       .setNetworkInterface(props.nonNullValue(ProcessProperties.CLUSTER_NODE_HOST))
       .setMembers(asList(props.nonNullValue(ProcessProperties.CLUSTER_HOSTS).split(",")))
       .setNodeType(NodeType.parse(props.nonNullValue(ProcessProperties.CLUSTER_NODE_TYPE)))

server/sonar-main/src/test/java/org/sonar/application/cluster/ClusterAppStateImplTest.java

@@ -141,7 +141,6 @@ public class ClusterAppStateImplTest {
     return new HazelcastMemberBuilder()
       .setNodeType(NodeType.APPLICATION)
       .setProcessId(ProcessId.COMPUTE_ENGINE)
-      .setClusterName("foo")
       .setNodeName("bar")
       .setPort(NetworkUtilsImpl.INSTANCE.getNextAvailablePort(loopback))
       .setNetworkInterface(loopback.getHostAddress())

server/sonar-process/src/main/java/org/sonar/process/cluster/hz/HazelcastMemberBuilder.java

@@ -41,7 +41,6 @@ import static java.util.Objects.requireNonNull;
 
 public class HazelcastMemberBuilder {
 
-  private String clusterName;
   private String nodeName;
   private int port;
   private NodeType nodeType;
@@ -49,11 +48,6 @@ public class HazelcastMemberBuilder {
   private String networkInterface;
   private List<String> members = new ArrayList<>();
 
-  public HazelcastMemberBuilder setClusterName(String s) {
-    this.clusterName = s;
-    return this;
-  }
-
   public HazelcastMemberBuilder setNodeName(String s) {
     this.nodeName = s;
     return this;
@@ -97,7 +91,11 @@ public class HazelcastMemberBuilder {
 
   public HazelcastMember build() {
     Config config = new Config();
-    config.getGroupConfig().setName(requireNonNull(clusterName, "Cluster name is missing"));
+    // do not use the value defined by property sonar.cluster.name.
+    // Hazelcast does not fail when joining a cluster with different name.
+    // Apparently this behavior exists since Hazelcast 3.8.2 (see note
+    // at http://docs.hazelcast.org/docs/3.8.6/manual/html-single/index.html#creating-cluster-groups)
+    config.getGroupConfig().setName("SonarQube");
 
     // Configure network
     NetworkConfig netConfig = config.getNetworkConfig();

server/sonar-process/src/test/java/org/sonar/process/cluster/hz/HazelcastMemberBuilderTest.java

@@ -47,7 +47,6 @@ public class HazelcastMemberBuilderTest {
     HazelcastMember member = underTest
       .setNodeType(NodeType.APPLICATION)
       .setProcessId(ProcessId.COMPUTE_ENGINE)
-      .setClusterName("foo")
       .setNodeName("bar")
       .setPort(NetworkUtilsImpl.INSTANCE.getNextAvailablePort(loopback))
       .setNetworkInterface(loopback.getHostAddress())

server/sonar-process/src/test/java/org/sonar/process/cluster/hz/HazelcastMemberImplTest.java

@@ -114,7 +114,6 @@ public class HazelcastMemberImplTest {
     return new HazelcastMemberBuilder()
       .setNodeType(NodeType.APPLICATION)
       .setProcessId(ProcessId.COMPUTE_ENGINE)
-      .setClusterName("foo")
       .setNodeName("name" + port)
       .setPort(port)
       .setNetworkInterface(loopback.getHostAddress())

server/sonar-server/src/main/java/org/sonar/server/cluster/StartableHazelcastMember.java

@@ -140,7 +140,6 @@ public class StartableHazelcastMember implements HazelcastMember, Startable {
       throw new IllegalStateException(format("Can not resolve address %s", networkAddress), e);
     }
     this.member = new HazelcastMemberBuilder()
-      .setClusterName(config.get(ProcessProperties.CLUSTER_NAME).orElseThrow(() -> new IllegalStateException("Missing cluster name")))
       .setNodeName(config.get(ProcessProperties.CLUSTER_NODE_NAME).orElseThrow(() -> new IllegalStateException("Missing node name")))
       .setNodeType(NodeType.parse(config.get(CLUSTER_NODE_TYPE).orElseThrow(() -> new IllegalStateException("Missing node type"))))
       .setPort(freePort)

tests/src/test/java/org/sonarqube/tests/cluster/ClusterTest.java

@@ -232,6 +232,24 @@ public class ClusterTest {
     }
   }
 
+  @Test
+  public void cluster_name_can_be_overridden() throws Exception {
+    try (Cluster cluster = new Cluster("foo")) {
+      NodeConfig searchConfig1 = newSearchConfig("Search 1");
+      NodeConfig searchConfig2 = newSearchConfig("Search 2");
+      NodeConfig appConfig = newApplicationConfig("App 1");
+      NodeConfig.interconnectBus(searchConfig1, searchConfig2, appConfig);
+      NodeConfig.interconnectSearch(searchConfig1, searchConfig2, appConfig);
+
+      cluster.startNode(searchConfig1, nothing());
+      cluster.startNode(searchConfig2, nothing());
+      cluster.startNode(appConfig, nothing());
+
+      Node appNode = cluster.getAppNode(0);
+      appNode.waitForStatusUp();
+    }
+  }
+
   @Test
   public void node_fails_to_join_cluster_if_different_cluster_name() throws Exception {
     try (Cluster cluster = new Cluster("foo")) {