From 683fb91669d6f386396b0850f17afdd02c26f868 Mon Sep 17 00:00:00 2001 From: liubin04 Date: Fri, 22 Jul 2022 17:14:17 +0800 Subject: [PATCH] YARN-11213. DecommissioningNodesWatcher#logDecommissioningNodesStatus calculate app elapsed time error --- .../server/resourcemanager/DecommissioningNodesWatcher.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/DecommissioningNodesWatcher.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/DecommissioningNodesWatcher.java index 61691690df8..70fc2ff08e1 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/DecommissioningNodesWatcher.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/DecommissioningNodesWatcher.java @@ -376,7 +376,7 @@ public class DecommissioningNodesWatcher { (rmApp.getApplicationType() == null)? "" : rmApp.getApplicationType(), 100.0 * rmApp.getProgress(), - (mclock.getTime() - rmApp.getStartTime()) / 1000)); + (System.currentTimeMillis() - rmApp.getStartTime()) / 1000)); } } LOG.debug("Decommissioning node: " + sb.toString());