From f4c8dc4783e95cf299efdf79c00499b62e3a5670 Mon Sep 17 00:00:00 2001 From: Karthik Kambatla Date: Thu, 10 Nov 2016 14:08:51 -0800 Subject: [PATCH] YARN-5834. TestNodeStatusUpdater.testNMRMConnectionConf compares nodemanager wait time to the incorrect value. (Chang Li via kasha) (cherry picked from commit 3a98419532687e4362ffc26abbc1264232820db7) --- .../yarn/server/nodemanager/TestNodeStatusUpdater.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/test/java/org/apache/hadoop/yarn/server/nodemanager/TestNodeStatusUpdater.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/test/java/org/apache/hadoop/yarn/server/nodemanager/TestNodeStatusUpdater.java index bc205b917a5..d76aa356697 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/test/java/org/apache/hadoop/yarn/server/nodemanager/TestNodeStatusUpdater.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/test/java/org/apache/hadoop/yarn/server/nodemanager/TestNodeStatusUpdater.java @@ -1523,13 +1523,13 @@ public class TestNodeStatusUpdater { long t = System.currentTimeMillis(); long duration = t - waitStartTime; boolean waitTimeValid = (duration >= nmRmConnectionWaitMs) && - (duration < (connectionWaitMs + delta)); + (duration < (nmRmConnectionWaitMs + delta)); if(!waitTimeValid) { // throw exception if NM doesn't retry long enough throw new Exception("NM should have tried re-connecting to RM during " + - "period of at least " + connectionWaitMs + " ms, but " + - "stopped retrying within " + (connectionWaitMs + delta) + + "period of at least " + nmRmConnectionWaitMs + " ms, but " + + "stopped retrying within " + (nmRmConnectionWaitMs + delta) + " ms: " + e, e); } }