Add flush and refresh

Signed-off-by: Craig Perkins <[email protected]>
cwperks · Dec 5, 2024 · 631d8c1 · 631d8c1
1 parent 8c5506a
commit 631d8c1
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/integrationTest/java/org/opensearch/test/framework/cluster/LocalOpenSearchCluster.java b/src/integrationTest/java/org/opensearch/test/framework/cluster/LocalOpenSearchCluster.java
@@ -227,6 +227,9 @@ public void stop(boolean checkActiveThreads) throws IOException {
         Client client = clientNode().getInternalNodeClient();
         AdminClient adminClient = client.admin();
 
+        adminClient.indices().prepareFlush().get();
+        adminClient.indices().prepareRefresh().get();
+
         if (checkActiveThreads) {
             int maxRetries = 3;
             int retryCount = 0;