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

create index and mapping first to ensure all relevant nodes see the mapping

This commit is contained in:
Simon Willnauer 2013-01-18 16:09:24 +01:00
parent 468295dc37
commit 6f38a3a8a8
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/test/java/org/elasticsearch/test/integration/mlt/MoreLikeThisActionTests.java
View File

@ -19,11 +19,14 @@
package org.elasticsearch.test.integration.mlt; package org.elasticsearch.test.integration.mlt;
import java.util.Collections;
import org.elasticsearch.action.admin.cluster.health.ClusterHealthResponse; import org.elasticsearch.action.admin.cluster.health.ClusterHealthResponse;
import org.elasticsearch.action.admin.cluster.health.ClusterHealthStatus; import org.elasticsearch.action.admin.cluster.health.ClusterHealthStatus;
import org.elasticsearch.action.search.SearchResponse; import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.Client; import org.elasticsearch.client.Client;
import org.elasticsearch.common.settings.ImmutableSettings; import org.elasticsearch.common.settings.ImmutableSettings;
import org.elasticsearch.common.xcontent.XContentFactory;
import org.elasticsearch.indices.IndexMissingException; import org.elasticsearch.indices.IndexMissingException;
import org.elasticsearch.test.integration.AbstractNodesTests; import org.elasticsearch.test.integration.AbstractNodesTests;
import org.testng.annotations.AfterClass; import org.testng.annotations.AfterClass;
@ -164,6 +167,11 @@ public class MoreLikeThisActionTests extends AbstractNodesTests {
client1.admin().indices().prepareDelete("foo").execute().actionGet(); client1.admin().indices().prepareDelete("foo").execute().actionGet();
} catch (IndexMissingException e) { } catch (IndexMissingException e) {
} }
String mapping = XContentFactory.jsonBuilder().startObject().startObject("bar")
.startObject("properties")
.endObject()
.endObject().endObject().string();
client1.admin().indices().prepareCreate("foo").addMapping("bar", mapping).execute().actionGet();
client1.prepareIndex("foo", "bar", "1") client1.prepareIndex("foo", "bar", "1")
.setSource(jsonBuilder().startObject().startObject("foo").field("bar", "boz").endObject()) .setSource(jsonBuilder().startObject().startObject("foo").field("bar", "boz").endObject())
.setRouting("2") .setRouting("2")