From 8b515ae46b8e60f94bb24f64fa4c521ac89ae705 Mon Sep 17 00:00:00 2001 From: Guangming Zhang Date: Fri, 24 Nov 2017 08:00:38 +0000 Subject: [PATCH] Thread.sleep() function is called to wait for NodeManager to identify disk failures. But the sleep time is too short so that the NodeManager may haven't finished identifying disk failures. So add the sleep time to 1500ms. Change-Id: I104db6d5c6a68d4f16a48260296926b09d3ba8f3 Jira: ENTWLS-191 --- .../src/test/java/org/apache/hadoop/yarn/server/TestDiskFailures.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-tests/src/test/java/org/apache/hadoop/yarn/server/TestDiskFailures.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-tests/src/test/java/org/apache/hadoop/yarn/server/TestDiskFailures.java index e9de20a..2ff6cf2 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-tests/src/test/java/org/apache/hadoop/yarn/server/TestDiskFailures.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-tests/src/test/java/org/apache/hadoop/yarn/server/TestDiskFailures.java @@ -210,7 +210,7 @@ private void waitForDiskHealthCheck() { long time = lastDisksCheckTime; for (int i = 0; i < 10 && (time <= lastDisksCheckTime); i++) { try { - Thread.sleep(1000); + Thread.sleep(1500); } catch(InterruptedException e) { LOG.error( "Interrupted while waiting for NodeManager's disk health check."); -- 2.7.4