test: force elasticsearch to index batch data (#11153)

influxdata · May 19, 2022 · 78d9262 · 78d9262
1 parent deb0c6e
commit 78d9262
Showing 1 changed file with 7 additions and 2 deletions.
diff --git a/plugins/inputs/elasticsearch_query/elasticsearch_query_test.go b/plugins/inputs/elasticsearch_query/elasticsearch_query_test.go
@@ -568,8 +568,13 @@ func setupIntegrationTest() error {
 		return err
 	}
 
-	// wait 5s (default) for Elasticsearch to index, so results are consistent
-	time.Sleep(time.Second * 5)
+	// force elastic to refresh indexes to get new batch data
+	ctx := context.Background()
+	_, err = e.esClient.Refresh().Do(ctx)
+	if err != nil {
+		return err
+	}
+
 	return nil
 }