[Bug] Wait for outstanding requests to complete (opensearch-project#1925

) Signed-off-by: Suraj Singh <[email protected]>
dreamer-89 · Jan 21, 2022 · 3d49672 · 3d49672
1 parent 5e2af8f
commit 3d49672
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/...er/src/internalClusterTest/java/org/opensearch/index/ShardIndexingPressureSettingsIT.java b/...er/src/internalClusterTest/java/org/opensearch/index/ShardIndexingPressureSettingsIT.java
@@ -403,6 +403,15 @@ public void testShardIndexingPressureEnforcedEnabledDisabledSetting() throws Exc
         secondSuccessFuture = client(coordinatingOnlyNode).bulk(bulkRequest);
         Thread.sleep(25);
 
+        assertBusy(
+            () -> {
+                assertEquals(
+                    coordinatingShardTracker.getCoordinatingOperationTracker().getPerformanceTracker().getTotalOutstandingRequests(),
+                    2
+                );
+            }
+        );
+
         // This request breaches the threshold and hence will be rejected
         expectThrows(OpenSearchRejectedExecutionException.class, () -> client(coordinatingOnlyNode).bulk(bulkRequest).actionGet());