diff --git a/server/src/internalClusterTest/java/org/opensearch/clustermanager/ClusterManagerTaskThrottlingIT.java b/server/src/internalClusterTest/java/org/opensearch/clustermanager/ClusterManagerTaskThrottlingIT.java index 2f3f0539602dd..328bc14883208 100644 --- a/server/src/internalClusterTest/java/org/opensearch/clustermanager/ClusterManagerTaskThrottlingIT.java +++ b/server/src/internalClusterTest/java/org/opensearch/clustermanager/ClusterManagerTaskThrottlingIT.java @@ -164,9 +164,9 @@ public void onResponse(Object o) { @Override public void onFailure(Exception e) { + timedoutRequest.incrementAndGet(); latch.countDown(); assertTrue(e instanceof ProcessClusterEventTimeoutException); - timedoutRequest.incrementAndGet(); } }; executePutMappingRequests(totalRequest, node, listener);