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

Adjust hlrc data streams integration test (#60804) 

Backport of #60746

to wait for at least a single shard to be allocated for a backing index of a data stream,
so that total store size is larger than zero (which is what the tests expects).

Closes #60461
This commit is contained in:
Martijn van Groningen 2020-08-06 11:57:12 +02:00 committed by GitHub
parent b210aaf666
commit 9163c9ce36
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
client/rest-high-level/src/test/java/org/elasticsearch/client/IndicesClientIT.java
View File

@ -2051,6 +2051,9 @@ public class IndicesClientIT extends ESRestHighLevelClientTestCase {
IndicesClient indices = highLevelClient().indices(); IndicesClient indices = highLevelClient().indices();
response = execute(createDataStreamRequest, indices::createDataStream, indices::createDataStreamAsync); response = execute(createDataStreamRequest, indices::createDataStream, indices::createDataStreamAsync);
assertThat(response.isAcknowledged(), equalTo(true)); assertThat(response.isAcknowledged(), equalTo(true));
ensureHealth(dataStreamName, (request -> {
request.addParameter("wait_for_status", "yellow");
}));
GetDataStreamRequest getDataStreamRequest = new GetDataStreamRequest(dataStreamName); GetDataStreamRequest getDataStreamRequest = new GetDataStreamRequest(dataStreamName);
GetDataStreamResponse getDataStreamResponse = execute(getDataStreamRequest, indices::getDataStream, indices::getDataStreamAsync); GetDataStreamResponse getDataStreamResponse = execute(getDataStreamRequest, indices::getDataStream, indices::getDataStreamAsync);