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

[TEST] Enforce that only one shard per node is allocated. The prevents during node shutdown, that a second shard is assigned the another node.

This commit is contained in:
Martijn van Groningen 2014-05-09 10:42:43 +02:00
parent bd2a616c82
commit 67fe88c63c
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/test/java/org/elasticsearch/search/scroll/SearchScrollWithFailingNodesTests.java
View File

@ -21,6 +21,8 @@ package org.elasticsearch.search.scroll;
import org.elasticsearch.action.index.IndexRequestBuilder; import org.elasticsearch.action.index.IndexRequestBuilder;
import org.elasticsearch.action.search.SearchResponse; import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.cluster.routing.allocation.decider.ShardsLimitAllocationDecider;
import org.elasticsearch.common.settings.ImmutableSettings;
import org.elasticsearch.common.unit.TimeValue; import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.test.ElasticsearchIntegrationTest; import org.elasticsearch.test.ElasticsearchIntegrationTest;
import org.elasticsearch.test.junit.annotations.TestLogging; import org.elasticsearch.test.junit.annotations.TestLogging;
@ -42,8 +44,7 @@ public class SearchScrollWithFailingNodesTests extends ElasticsearchIntegrationT
@Override @Override
protected int numberOfShards() { protected int numberOfShards() {
// We need at least 2 primary shards, otherwise a stopping a node isn't going to result into shard failures. return 2;
return between(2, 6);
} }
@Override @Override
@ -56,6 +57,8 @@ public class SearchScrollWithFailingNodesTests extends ElasticsearchIntegrationT
public void testScanScrollWithShardExceptions() throws Exception { public void testScanScrollWithShardExceptions() throws Exception {
assertAcked( assertAcked(
prepareCreate("test") prepareCreate("test")
// Enforces that only one shard can only be allocated to a single node
.setSettings(ImmutableSettings.builder().put(indexSettings()).put(ShardsLimitAllocationDecider.INDEX_TOTAL_SHARDS_PER_NODE, 1))
); );
List<IndexRequestBuilder> writes = new ArrayList<>(); List<IndexRequestBuilder> writes = new ArrayList<>();