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

Attempt to fix "No active shards" failure

This commit is contained in:
Martijn van Groningen 2013-02-07 10:14:10 +01:00
parent ed43ad07d7
commit e72e323c8a
1 changed files with 27 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
src/test/java/org/elasticsearch/test/integration/search/suggest/SuggestSearchTests.java
View File

@ -31,6 +31,9 @@ import java.util.Arrays;
import java.util.HashMap; import java.util.HashMap;
import java.util.Map; import java.util.Map;
import static org.elasticsearch.cluster.metadata.IndexMetaData.SETTING_NUMBER_OF_REPLICAS;
import static org.elasticsearch.cluster.metadata.IndexMetaData.SETTING_NUMBER_OF_SHARDS;
import static org.elasticsearch.common.settings.ImmutableSettings.settingsBuilder;
import static org.elasticsearch.index.query.QueryBuilders.matchQuery; import static org.elasticsearch.index.query.QueryBuilders.matchQuery;
import static org.elasticsearch.search.suggest.SuggestBuilder.fuzzySuggestion; import static org.elasticsearch.search.suggest.SuggestBuilder.fuzzySuggestion;
import static org.hamcrest.MatcherAssert.assertThat; import static org.hamcrest.MatcherAssert.assertThat;
@ -63,7 +66,12 @@ public class SuggestSearchTests extends AbstractNodesTests {
@Test @Test
public void testSimple() throws Exception { public void testSimple() throws Exception {
client.admin().indices().prepareDelete().execute().actionGet(); client.admin().indices().prepareDelete().execute().actionGet();
client.admin().indices().prepareCreate("test").execute().actionGet(); client.admin().indices().prepareCreate("test")
.setSettings(settingsBuilder()
.put(SETTING_NUMBER_OF_SHARDS, 5)
.put(SETTING_NUMBER_OF_REPLICAS, 0))
.execute().actionGet();
client.admin().cluster().prepareHealth("test").setWaitForGreenStatus().execute().actionGet();
client.prepareIndex("test", "type1") client.prepareIndex("test", "type1")
.setSource(XContentFactory.jsonBuilder() .setSource(XContentFactory.jsonBuilder()
@ -135,8 +143,12 @@ public class SuggestSearchTests extends AbstractNodesTests {
@Test @Test
public void testEmpty() throws Exception { public void testEmpty() throws Exception {
client.admin().indices().prepareDelete().execute().actionGet(); client.admin().indices().prepareDelete().execute().actionGet();
client.admin().indices().prepareCreate("test").execute().actionGet(); client.admin().indices().prepareCreate("test")
client.admin().cluster().prepareHealth().setWaitForYellowStatus().execute().actionGet(); .setSettings(settingsBuilder()
.put(SETTING_NUMBER_OF_SHARDS, 5)
.put(SETTING_NUMBER_OF_REPLICAS, 0))
.execute().actionGet();
client.admin().cluster().prepareHealth("test").setWaitForGreenStatus().execute().actionGet();
SearchResponse search = client.prepareSearch() SearchResponse search = client.prepareSearch()
.setQuery(matchQuery("text", "spellcecker")) .setQuery(matchQuery("text", "spellcecker"))
@ -172,7 +184,12 @@ public class SuggestSearchTests extends AbstractNodesTests {
@Test @Test
public void testWithMultipleCommands() throws Exception { public void testWithMultipleCommands() throws Exception {
client.admin().indices().prepareDelete().execute().actionGet(); client.admin().indices().prepareDelete().execute().actionGet();
client.admin().indices().prepareCreate("test").execute().actionGet(); client.admin().indices().prepareCreate("test")
.setSettings(settingsBuilder()
.put(SETTING_NUMBER_OF_SHARDS, 5)
.put(SETTING_NUMBER_OF_REPLICAS, 0))
.execute().actionGet();
client.admin().cluster().prepareHealth("test").setWaitForGreenStatus().execute().actionGet();
client.prepareIndex("test", "type1") client.prepareIndex("test", "type1")
.setSource(XContentFactory.jsonBuilder() .setSource(XContentFactory.jsonBuilder()
@ -247,7 +264,12 @@ public class SuggestSearchTests extends AbstractNodesTests {
@Test @Test
public void testSizeAndSort() throws Exception { public void testSizeAndSort() throws Exception {
client.admin().indices().prepareDelete().execute().actionGet(); client.admin().indices().prepareDelete().execute().actionGet();
client.admin().indices().prepareCreate("test").execute().actionGet(); client.admin().indices().prepareCreate("test")
.setSettings(settingsBuilder()
.put(SETTING_NUMBER_OF_SHARDS, 5)
.put(SETTING_NUMBER_OF_REPLICAS, 0))
.execute().actionGet();
client.admin().cluster().prepareHealth("test").setWaitForGreenStatus().execute().actionGet();
Map<String, Integer> termsAndDocCount = new HashMap<String, Integer>(); Map<String, Integer> termsAndDocCount = new HashMap<String, Integer>();
termsAndDocCount.put("prefix_aaad", 20); termsAndDocCount.put("prefix_aaad", 20);