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/19c2c22b Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/19c2c22b Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/19c2c22b Branch: refs/heads/branch-2 Commit: 19c2c22bbe661f9e628f2043313079c95f1a6971 Parents: 45bb467 Author: Arpit Agarwal <a...@apache.org> Authored: Tue Dec 1 09:27:23 2015 -0800 Committer: Arpit Agarwal <a...@apache.org> Committed: Tue Dec 1 09:29:07 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/19c2c22b/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 89be920..49ee0e6 100644 --- a/hadoop-common-project/hadoop-common/CHANGES.txt +++ b/hadoop-common-project/hadoop-common/CHANGES.txt @@ -872,6 +872,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/19c2c22b/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);
