HADOOP-14166. Reset the DecayRpcScheduler AvgResponseTime metric to zero when queue is not used. Contributed by Surendra Singh Lilhore.
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/dcf4559e Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/dcf4559e Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/dcf4559e Branch: refs/heads/YARN-1011 Commit: dcf4559ebdb5bb11d03b264a9875bff316b89eef Parents: b7a0c0e Author: Brahma Reddy Battula <bra...@apache.org> Authored: Thu May 25 01:27:13 2017 +0800 Committer: Brahma Reddy Battula <bra...@apache.org> Committed: Thu May 25 01:27:13 2017 +0800 ---------------------------------------------------------------------- .../src/main/java/org/apache/hadoop/ipc/DecayRpcScheduler.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/dcf4559e/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/DecayRpcScheduler.java ---------------------------------------------------------------------- diff --git a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/DecayRpcScheduler.java b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/DecayRpcScheduler.java index 3c09625..5ae4e8b 100644 --- a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/DecayRpcScheduler.java +++ b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/DecayRpcScheduler.java @@ -618,6 +618,8 @@ public class DecayRpcScheduler implements RpcScheduler, } else { responseTimeAvgInLastWindow.set(i, averageResponseTime); } + } else { + responseTimeAvgInLastWindow.set(i, 0); } responseTimeCountInLastWindow.set(i, responseTimeCount); if (LOG.isDebugEnabled()) { --------------------------------------------------------------------- To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-commits-h...@hadoop.apache.org