spotless

Signed-off-by: chenweiguo.vc <[email protected]>
opensearch-project · Nov 30, 2023 · e0dc0ef · e0dc0ef
1 parent 0b55aaa
commit e0dc0ef
Showing 1 changed file with 39 additions and 13 deletions.
diff --git a/server/src/test/java/org/opensearch/cluster/routing/allocation/SameShardRoutingTests.java b/server/src/test/java/org/opensearch/cluster/routing/allocation/SameShardRoutingTests.java
@@ -194,25 +194,51 @@ public void testForceAllocatePrimaryOnSameNodeNotAllowed() {
 
     public void testRelocateBetweenNodesInSameHost() {
         AllocationService strategy = createAllocationService(
-                Settings.builder().put(SameShardAllocationDecider.CLUSTER_ROUTING_ALLOCATION_SAME_HOST_SETTING.getKey(), true).build());
+            Settings.builder().put(SameShardAllocationDecider.CLUSTER_ROUTING_ALLOCATION_SAME_HOST_SETTING.getKey(), true).build()
+        );
 
         Metadata metaData = Metadata.builder()
-                .put(IndexMetadata.builder("test").settings(settings(Version.CURRENT)).numberOfShards(1).numberOfReplicas(0))
-                .build();
+            .put(IndexMetadata.builder("test").settings(settings(Version.CURRENT)).numberOfShards(1).numberOfReplicas(0))
+            .build();
 
-        RoutingTable routingTable = RoutingTable.builder()
-                .addAsNew(metaData.index("test"))
-                .build();
-        ClusterState clusterState = ClusterState.builder(ClusterName.CLUSTER_NAME_SETTING.getDefault(Settings.EMPTY)).metadata(metaData)
-                .routingTable(routingTable).build();
+        RoutingTable routingTable = RoutingTable.builder().addAsNew(metaData.index("test")).build();
+        ClusterState clusterState = ClusterState.builder(ClusterName.CLUSTER_NAME_SETTING.getDefault(Settings.EMPTY))
+            .metadata(metaData)
+            .routingTable(routingTable)
+            .build();
 
         logger.info("--> adding two nodes with the same host");
-        clusterState = ClusterState.builder(clusterState).nodes(
+        clusterState = ClusterState.builder(clusterState)
+            .nodes(
                 DiscoveryNodes.builder()
-                        .add(new DiscoveryNode("node1", "node1", "node1", "test1", "test1", buildNewFakeTransportAddress(), emptyMap(),
-                                CLUSTER_MANAGER_DATA_ROLES, Version.CURRENT))
-                        .add(new DiscoveryNode("node2", "node2", "node2", "test1", "test1", buildNewFakeTransportAddress(), emptyMap(),
-                                CLUSTER_MANAGER_DATA_ROLES, Version.CURRENT))).build();
+                    .add(
+                        new DiscoveryNode(
+                            "node1",
+                            "node1",
+                            "node1",
+                            "test1",
+                            "test1",
+                            buildNewFakeTransportAddress(),
+                            emptyMap(),
+                            CLUSTER_MANAGER_DATA_ROLES,
+                            Version.CURRENT
+                        )
+                    )
+                    .add(
+                        new DiscoveryNode(
+                            "node2",
+                            "node2",
+                            "node2",
+                            "test1",
+                            "test1",
+                            buildNewFakeTransportAddress(),
+                            emptyMap(),
+                            CLUSTER_MANAGER_DATA_ROLES,
+                            Version.CURRENT
+                        )
+                    )
+            )
+            .build();
         clusterState = strategy.reroute(clusterState, "reroute");
 
         assertThat(numberOfShardsOfType(clusterState.getRoutingNodes(), ShardRoutingState.INITIALIZING), equalTo(1));