Skip to content

Commit 00ae0c6

Browse files
committed
Don't assume bulks have finished before we call refresh
1 parent 25afbf6 commit 00ae0c6

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

x-pack/plugin/analytics/src/test/java/org/elasticsearch/xpack/analytics/aggregations/metrics/HistogramPercentileAggregationTests.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -82,7 +82,7 @@ public void testHDRHistogram() throws Exception {
8282
bulkRequest.add(new IndexRequest("raw").source(doc));
8383
histogram.recordValue(value);
8484
if ((i + 1) % frq == 0) {
85-
client().bulk(bulkRequest);
85+
client().bulk(bulkRequest).actionGet();
8686
bulkRequest = new BulkRequest();
8787
List<Double> values = new ArrayList<>();
8888
List<Integer> counts = new ArrayList<>();
@@ -186,7 +186,7 @@ private void setupTDigestHistogram(int compression) throws Exception {
186186
bulkRequest.add(new IndexRequest("raw").source(doc));
187187
histogram.add(value);
188188
if ((i + 1) % frq == 0) {
189-
client().bulk(bulkRequest);
189+
client().bulk(bulkRequest).actionGet();
190190
bulkRequest = new BulkRequest();
191191
List<Double> values = new ArrayList<>();
192192
List<Long> counts = new ArrayList<>();

0 commit comments

Comments
 (0)