You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by br...@apache.org on 2017/05/24 17:28:49 UTC

[1/3] hadoop git commit: HADOOP-14166. Reset the DecayRpcScheduler AvgResponseTime metric to zero when queue is not used. Contributed by Surendra Singh Lilhore.

Repository: hadoop
Updated Branches:
  refs/heads/branch-2 e3a65b24b -> 6f55be197
  refs/heads/branch-2.8 cf4e6d6b1 -> d9492839d
  refs/heads/trunk b7a0c0e70 -> dcf4559eb


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/trunk
Commit: dcf4559ebdb5bb11d03b264a9875bff316b89eef
Parents: b7a0c0e
Author: Brahma Reddy Battula <br...@apache.org>
Authored: Thu May 25 01:27:13 2017 +0800
Committer: Brahma Reddy Battula <br...@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-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org


[2/3] hadoop git commit: HADOOP-14166. Reset the DecayRpcScheduler AvgResponseTime metric to zero when queue is not used. Contributed by Surendra Singh Lilhore.

Posted by br...@apache.org.
HADOOP-14166. Reset the DecayRpcScheduler AvgResponseTime metric to zero when queue is not used. Contributed by Surendra Singh Lilhore.

(cherry picked from commit dcf4559ebdb5bb11d03b264a9875bff316b89eef)


Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/6f55be19
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/6f55be19
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/6f55be19

Branch: refs/heads/branch-2
Commit: 6f55be197cef901d79110d652bf4f0b12a58004a
Parents: e3a65b2
Author: Brahma Reddy Battula <br...@apache.org>
Authored: Thu May 25 01:27:13 2017 +0800
Committer: Brahma Reddy Battula <br...@apache.org>
Committed: Thu May 25 01:27:52 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/6f55be19/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 537de37..fe9298f 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-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org


[3/3] hadoop git commit: HADOOP-14166. Reset the DecayRpcScheduler AvgResponseTime metric to zero when queue is not used. Contributed by Surendra Singh Lilhore.

Posted by br...@apache.org.
HADOOP-14166. Reset the DecayRpcScheduler AvgResponseTime metric to zero when queue is not used. Contributed by Surendra Singh Lilhore.

(cherry picked from commit dcf4559ebdb5bb11d03b264a9875bff316b89eef)


Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/d9492839
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/d9492839
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/d9492839

Branch: refs/heads/branch-2.8
Commit: d9492839d02ea51c8a8f6b8152ebd50369be59d0
Parents: cf4e6d6
Author: Brahma Reddy Battula <br...@apache.org>
Authored: Thu May 25 01:27:13 2017 +0800
Committer: Brahma Reddy Battula <br...@apache.org>
Committed: Thu May 25 01:28:36 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/d9492839/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 537de37..fe9298f 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-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org