diff options
Diffstat (limited to 'core/src/test/java/org/elasticsearch/cluster/routing/allocation/AwarenessAllocationTests.java')
-rw-r--r-- | core/src/test/java/org/elasticsearch/cluster/routing/allocation/AwarenessAllocationTests.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/core/src/test/java/org/elasticsearch/cluster/routing/allocation/AwarenessAllocationTests.java b/core/src/test/java/org/elasticsearch/cluster/routing/allocation/AwarenessAllocationTests.java index eb94b6de10..8810fc4739 100644 --- a/core/src/test/java/org/elasticsearch/cluster/routing/allocation/AwarenessAllocationTests.java +++ b/core/src/test/java/org/elasticsearch/cluster/routing/allocation/AwarenessAllocationTests.java @@ -872,10 +872,10 @@ public class AwarenessAllocationTests extends ESAllocationTestCase { if (routing.primary()) { primaryNode = routing.currentNodeId(); } else if (routing.initializing()) { - commands.add(new CancelAllocationCommand(routing.shardId(), routing.currentNodeId(), false)); + commands.add(new CancelAllocationCommand(routing.shardId().getIndexName(), routing.id(), routing.currentNodeId(), false)); } } - commands.add(new MoveAllocationCommand(new ShardId("test", 0), primaryNode, "A-4")); + commands.add(new MoveAllocationCommand("test", 0, primaryNode, "A-4")); routingTable = strategy.reroute(clusterState, commands).routingTable(); clusterState = ClusterState.builder(clusterState).routingTable(routingTable).build(); |