@@ -194,25 +194,51 @@ public void testForceAllocatePrimaryOnSameNodeNotAllowed() {
194
194
195
195
public void testRelocateBetweenNodesInSameHost () {
196
196
AllocationService strategy = createAllocationService (
197
- Settings .builder ().put (SameShardAllocationDecider .CLUSTER_ROUTING_ALLOCATION_SAME_HOST_SETTING .getKey (), true ).build ());
197
+ Settings .builder ().put (SameShardAllocationDecider .CLUSTER_ROUTING_ALLOCATION_SAME_HOST_SETTING .getKey (), true ).build ()
198
+ );
198
199
199
200
Metadata metaData = Metadata .builder ()
200
- .put (IndexMetadata .builder ("test" ).settings (settings (Version .CURRENT )).numberOfShards (1 ).numberOfReplicas (0 ))
201
- .build ();
201
+ .put (IndexMetadata .builder ("test" ).settings (settings (Version .CURRENT )).numberOfShards (1 ).numberOfReplicas (0 ))
202
+ .build ();
202
203
203
- RoutingTable routingTable = RoutingTable .builder ()
204
- . addAsNew ( metaData . index ( "test" ))
205
- . build ();
206
- ClusterState clusterState = ClusterState . builder ( ClusterName . CLUSTER_NAME_SETTING . getDefault ( Settings . EMPTY )). metadata ( metaData )
207
- . routingTable ( routingTable ) .build ();
204
+ RoutingTable routingTable = RoutingTable .builder (). addAsNew ( metaData . index ( "test" )). build ();
205
+ ClusterState clusterState = ClusterState . builder ( ClusterName . CLUSTER_NAME_SETTING . getDefault ( Settings . EMPTY ))
206
+ . metadata ( metaData )
207
+ . routingTable ( routingTable )
208
+ .build ();
208
209
209
210
logger .info ("--> adding two nodes with the same host" );
210
- clusterState = ClusterState .builder (clusterState ).nodes (
211
+ clusterState = ClusterState .builder (clusterState )
212
+ .nodes (
211
213
DiscoveryNodes .builder ()
212
- .add (new DiscoveryNode ("node1" , "node1" , "node1" , "test1" , "test1" , buildNewFakeTransportAddress (), emptyMap (),
213
- CLUSTER_MANAGER_DATA_ROLES , Version .CURRENT ))
214
- .add (new DiscoveryNode ("node2" , "node2" , "node2" , "test1" , "test1" , buildNewFakeTransportAddress (), emptyMap (),
215
- CLUSTER_MANAGER_DATA_ROLES , Version .CURRENT ))).build ();
214
+ .add (
215
+ new DiscoveryNode (
216
+ "node1" ,
217
+ "node1" ,
218
+ "node1" ,
219
+ "test1" ,
220
+ "test1" ,
221
+ buildNewFakeTransportAddress (),
222
+ emptyMap (),
223
+ CLUSTER_MANAGER_DATA_ROLES ,
224
+ Version .CURRENT
225
+ )
226
+ )
227
+ .add (
228
+ new DiscoveryNode (
229
+ "node2" ,
230
+ "node2" ,
231
+ "node2" ,
232
+ "test1" ,
233
+ "test1" ,
234
+ buildNewFakeTransportAddress (),
235
+ emptyMap (),
236
+ CLUSTER_MANAGER_DATA_ROLES ,
237
+ Version .CURRENT
238
+ )
239
+ )
240
+ )
241
+ .build ();
216
242
clusterState = strategy .reroute (clusterState , "reroute" );
217
243
218
244
assertThat (numberOfShardsOfType (clusterState .getRoutingNodes (), ShardRoutingState .INITIALIZING ), equalTo (1 ));
0 commit comments