Update delay to 500 since still we see failure for cluster state

Signed-off-by: pranikum <109206473+pranikum@users.noreply.github.com>
opensearch-project · Oct 21, 2022 · 10a6e5f · 10a6e5f
1 parent b724464
commit 10a6e5f
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...lusterTest/java/org/opensearch/cluster/coordination/AwarenessAttributeDecommissionIT.java b/...lusterTest/java/org/opensearch/cluster/coordination/AwarenessAttributeDecommissionIT.java
@@ -128,7 +128,7 @@ public void testDecommissionStatusUpdatePublishedToAllNodes() throws ExecutionEx
 
         logger.info("--> Received decommissioning nodes in zone {}", 'c');
         // Keep some delay for scheduler to invoke decommission flow
-        Thread.sleep(300);
+        Thread.sleep(500);
 
         // Will wait for all events to complete
         client().admin().cluster().prepareHealth().setWaitForEvents(Priority.LANGUID).get();

diff --git a/server/src/main/java/org/opensearch/rest/action/admin/cluster/RestDecommissionAction.java b/server/src/main/java/org/opensearch/rest/action/admin/cluster/RestDecommissionAction.java
@@ -55,7 +55,7 @@ DecommissionRequest createRequest(RestRequest request) throws IOException {
         TimeValue delayTimeout = DecommissionRequest.DEFAULT_NODE_DRAINING_TIMEOUT;
         if (noDelay) {
             decommissionRequest.setNoDelay(noDelay);
-            delayTimeout = TimeValue.timeValueSeconds(0);
+            delayTimeout = TimeValue.ZERO;
         }
         decommissionRequest.setDecommissionAttribute(new DecommissionAttribute(attributeName, attributeValue));
         return decommissionRequest.setDelayTimeout(delayTimeout);