Skip to content

Commit

Permalink
Update LogsIndexingIT.java
Browse files Browse the repository at this point in the history
  • Loading branch information
kkrik-es authored Dec 19, 2024
1 parent 63eaf7e commit fa4f745
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -192,7 +192,7 @@ private void checkIndexSearchAndRetrieval(String dataStreamName, boolean routeOn
var searchRequest = new SearchRequest(dataStreamName);
searchRequest.source().trackTotalHits(true);
assertResponse(client().search(searchRequest), searchResponse -> {
assertThat(searchResponse.getHits().getTotalHits().value(), equalTo((long) numBulkRequests * numDocsPerBulk));
assertThat(searchResponse.getHits().getTotalHits().value, equalTo((long) numBulkRequests * numDocsPerBulk));

for (int i = 0; i < searchResponse.getHits().getHits().length; i++) {
String id = searchResponse.getHits().getHits()[i].getId();
Expand Down

0 comments on commit fa4f745

Please sign in to comment.