honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[TEST] Additional logging for testDelayedUnassignedScheduleReroute 

Relates to #13485
This commit is contained in:
Lee Hinman 2015-09-10 11:43:44 -06:00
parent 47de1bd923
commit b21d3d2fb5
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
core/src/test/java/org/elasticsearch/cluster/routing/RoutingServiceTests.java
View File

@ -30,6 +30,7 @@ import org.elasticsearch.cluster.routing.allocation.AllocationService;
import org.elasticsearch.common.settings.Settings; import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.unit.TimeValue; import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.test.ESAllocationTestCase; import org.elasticsearch.test.ESAllocationTestCase;
import org.elasticsearch.test.junit.annotations.TestLogging;
import org.elasticsearch.threadpool.ThreadPool; import org.elasticsearch.threadpool.ThreadPool;
import org.junit.After; import org.junit.After;
import org.junit.Before; import org.junit.Before;
@ -93,6 +94,7 @@ public class RoutingServiceTests extends ESAllocationTestCase {
} }
@Test @Test
@TestLogging("_root:DEBUG")
public void testDelayedUnassignedScheduleReroute() throws Exception { public void testDelayedUnassignedScheduleReroute() throws Exception {
AllocationService allocation = createAllocationService(); AllocationService allocation = createAllocationService();
MetaData metaData = MetaData.builder() MetaData metaData = MetaData.builder()
@ -108,7 +110,7 @@ public class RoutingServiceTests extends ESAllocationTestCase {
clusterState = ClusterState.builder(clusterState).routingResult(allocation.applyStartedShards(clusterState, clusterState.getRoutingNodes().shardsWithState(INITIALIZING))).build(); clusterState = ClusterState.builder(clusterState).routingResult(allocation.applyStartedShards(clusterState, clusterState.getRoutingNodes().shardsWithState(INITIALIZING))).build();
// starting replicas // starting replicas
clusterState = ClusterState.builder(clusterState).routingResult(allocation.applyStartedShards(clusterState, clusterState.getRoutingNodes().shardsWithState(INITIALIZING))).build(); clusterState = ClusterState.builder(clusterState).routingResult(allocation.applyStartedShards(clusterState, clusterState.getRoutingNodes().shardsWithState(INITIALIZING))).build();
assertThat(clusterState.getRoutingNodes().hasUnassigned(), equalTo(false)); assertFalse("no shards should be unassigned", clusterState.getRoutingNodes().hasUnassigned());
// remove node2 and reroute // remove node2 and reroute
ClusterState prevState = clusterState; ClusterState prevState = clusterState;
clusterState = ClusterState.builder(clusterState).nodes(DiscoveryNodes.builder(clusterState.nodes()).remove("node2")).build(); clusterState = ClusterState.builder(clusterState).nodes(DiscoveryNodes.builder(clusterState.nodes()).remove("node2")).build();
@ -123,7 +125,7 @@ public class RoutingServiceTests extends ESAllocationTestCase {
assertBusy(new Runnable() { assertBusy(new Runnable() {
@Override @Override
public void run() { public void run() {
assertThat(routingService.hasReroutedAndClear(), equalTo(true)); assertTrue("routing service should have run a reroute", routingService.hasReroutedAndClear());
} }
}); });
// verify the registration has been reset // verify the registration has been reset
@ -186,6 +188,7 @@ public class RoutingServiceTests extends ESAllocationTestCase {
@Override @Override
protected void performReroute(String reason) { protected void performReroute(String reason) {
logger.info("--> performing fake reroute [{}]", reason);
rerouted.set(true); rerouted.set(true);
} }
} }