Test: add document indexing back to testCancellationCleansTempFiles
It was lost during a merge conflict in 796aa5c3fe2424390a8edee604cd292b8afdf514
This commit is contained in:
parent
dfc0496fc0
commit
1b7920f202
|
@ -542,6 +542,13 @@ public class RelocationTests extends ElasticsearchIntegrationTest {
|
||||||
.setSettings(ImmutableSettings.builder().put(IndexMetaData.SETTING_NUMBER_OF_SHARDS, 1, IndexMetaData.SETTING_NUMBER_OF_REPLICAS, 0)).get();
|
.setSettings(ImmutableSettings.builder().put(IndexMetaData.SETTING_NUMBER_OF_SHARDS, 1, IndexMetaData.SETTING_NUMBER_OF_REPLICAS, 0)).get();
|
||||||
|
|
||||||
internalCluster().startNodesAsync(2).get();
|
internalCluster().startNodesAsync(2).get();
|
||||||
|
|
||||||
|
List<IndexRequestBuilder> requests = new ArrayList<>();
|
||||||
|
int numDocs = scaledRandomIntBetween(25, 250);
|
||||||
|
for (int i = 0; i < numDocs; i++) {
|
||||||
|
requests.add(client().prepareIndex(indexName, "type").setCreate(true).setSource("{}"));
|
||||||
|
}
|
||||||
|
indexRandom(true, requests);
|
||||||
assertFalse(client().admin().cluster().prepareHealth().setWaitForNodes("3").setWaitForGreenStatus().get().isTimedOut());
|
assertFalse(client().admin().cluster().prepareHealth().setWaitForNodes("3").setWaitForGreenStatus().get().isTimedOut());
|
||||||
flush();
|
flush();
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue