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 as...@apache.org on 2015/12/06 08:13:12 UTC
[10/38] hadoop git commit: HADOOP-12609. Fix intermittent failure of
TestDecayRpcScheduler. (Contributed by Masatake Iwasaki)
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 <ar...@apache.org>
Authored: Tue Dec 1 09:27:23 2015 -0800
Committer: Arpit Agarwal <ar...@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);