HDFS-9911. TestDataNodeLifeline Fails intermittently. Contributed by Yiqun Lin
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/a9563906 Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/a9563906 Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/a9563906 Branch: refs/heads/YARN-5085 Commit: a95639068c99ebcaefe8b6c4268449d12a6577d6 Parents: 2273a74 Author: Anu Engineer <[email protected]> Authored: Fri Dec 16 09:46:21 2016 -0800 Committer: Anu Engineer <[email protected]> Committed: Fri Dec 16 09:46:21 2016 -0800 ---------------------------------------------------------------------- .../org/apache/hadoop/hdfs/server/datanode/BPServiceActor.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/a9563906/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BPServiceActor.java ---------------------------------------------------------------------- diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BPServiceActor.java b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BPServiceActor.java index 25ab3b7..5294799 100644 --- a/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BPServiceActor.java +++ b/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BPServiceActor.java @@ -1068,7 +1068,7 @@ class BPServiceActor implements Runnable { volatile long nextHeartbeatTime = monotonicNow(); @VisibleForTesting - volatile long nextLifelineTime = monotonicNow(); + volatile long nextLifelineTime; @VisibleForTesting volatile long lastBlockReportTime = monotonicNow(); @@ -1091,6 +1091,7 @@ class BPServiceActor implements Runnable { this.heartbeatIntervalMs = heartbeatIntervalMs; this.lifelineIntervalMs = lifelineIntervalMs; this.blockReportIntervalMs = blockReportIntervalMs; + scheduleNextLifeline(nextHeartbeatTime); } // This is useful to make sure NN gets Heartbeat before Blockreport --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
