diff --git a/server/src/internalClusterTest/java/org/opensearch/clustermanager/ClusterManagerTaskThrottlingIT.java b/server/src/internalClusterTest/java/org/opensearch/clustermanager/ClusterManagerTaskThrottlingIT.java index 2f3f0539602dd..9817861c88e9a 100644 --- a/server/src/internalClusterTest/java/org/opensearch/clustermanager/ClusterManagerTaskThrottlingIT.java +++ b/server/src/internalClusterTest/java/org/opensearch/clustermanager/ClusterManagerTaskThrottlingIT.java @@ -116,8 +116,8 @@ public void testThrottlingForSingleNode() throws Exception { ActionListener listener = new ActionListener() { @Override public void onResponse(Object o) { - latch.countDown(); successfulRequest.incrementAndGet(); + latch.countDown(); } @Override @@ -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);