hadoop-common-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From asur...@apache.org
Subject [10/38] hadoop git commit: HADOOP-12609. Fix intermittent failure of TestDecayRpcScheduler. (Contributed by Masatake Iwasaki)
Date Sun, 06 Dec 2015 07:13:12 GMT
HADOOP-12609. Fix intermittent failure of TestDecayRpcScheduler. (Contributed by Masatake Iwasaki)


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

Branch: refs/heads/yarn-2877
Commit: 485c3468a8520fcde14800af3e4a075231c946de
Parents: 0288942
Author: Arpit Agarwal <arp@apache.org>
Authored: Tue Dec 1 09:27:23 2015 -0800
Committer: Arpit Agarwal <arp@apache.org>
Committed: Tue Dec 1 09:27:23 2015 -0800

----------------------------------------------------------------------
 hadoop-common-project/hadoop-common/CHANGES.txt                   | 3 +++
 .../src/main/java/org/apache/hadoop/ipc/DecayRpcScheduler.java    | 2 +-
 2 files changed, 4 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hadoop/blob/485c3468/hadoop-common-project/hadoop-common/CHANGES.txt
----------------------------------------------------------------------
diff --git a/hadoop-common-project/hadoop-common/CHANGES.txt b/hadoop-common-project/hadoop-common/CHANGES.txt
index 32f6905..b19b703 100644
--- a/hadoop-common-project/hadoop-common/CHANGES.txt
+++ b/hadoop-common-project/hadoop-common/CHANGES.txt
@@ -1491,6 +1491,9 @@ Release 2.8.0 - UNRELEASED
     HADOOP-12313. NPE in JvmPauseMonitor when calling stop() before start().
     (Gabor Liptak via wheat9)
 
+    HADOOP-12609. Fix intermittent failure of TestDecayRpcScheduler.
+    (Masatake Iwasaki via Arpit Agarwal)
+
 Release 2.7.3 - UNRELEASED
 
   INCOMPATIBLE CHANGES

http://git-wip-us.apache.org/repos/asf/hadoop/blob/485c3468/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 d06b25c..a6a14d0 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
@@ -151,7 +151,7 @@ public class DecayRpcScheduler implements RpcScheduler, DecayRpcSchedulerMXBean
     // Setup delay timer
     Timer timer = new Timer();
     DecayTask task = new DecayTask(this, timer);
-    timer.scheduleAtFixedRate(task, 0, this.decayPeriodMillis);
+    timer.scheduleAtFixedRate(task, decayPeriodMillis, decayPeriodMillis);
 
     MetricsProxy prox = MetricsProxy.getInstance(ns);
     prox.setDelegate(this);


Mime
View raw message