Author: vinodkv
Date: Fri Nov 30 20:46:14 2012
New Revision: 1415848
URL: http://svn.apache.org/viewvc?rev=1415848&view=rev
Log:
MAPREDUCE-4478. Fixed a bug in TaskTracker's heartbeat to keep it under
control. (Liyin Liang via vinodkv)
Modified:
hadoop/common/branches/branch-1/CHANGES.txt
hadoop/common/branches/branch-1/src/mapred/org/apache/hadoop/mapred/TaskTracker.java
Modified: hadoop/common/branches/branch-1/CHANGES.txt
URL:
http://svn.apache.org/viewvc/hadoop/common/branches/branch-1/CHANGES.txt?rev=1415848&r1=1415847&r2=1415848&view=diff
==============================================================================
--- hadoop/common/branches/branch-1/CHANGES.txt (original)
+++ hadoop/common/branches/branch-1/CHANGES.txt Fri Nov 30 20:46:14 2012
@@ -394,6 +394,9 @@ Release 1.1.1 - Unreleased
HADOOP-8745. Incorrect version numbers in hadoop-core POM.
(Matthias Friedrich via eli)
+ MAPREDUCE-4478. Fixed a bug in TaskTracker's heartbeat to keep it under
+ control. (Liyin Liang via vinodkv)
+
Release 1.1.0 - 2012.09.28
INCOMPATIBLE CHANGES
Modified:
hadoop/common/branches/branch-1/src/mapred/org/apache/hadoop/mapred/TaskTracker.java
URL:
http://svn.apache.org/viewvc/hadoop/common/branches/branch-1/src/mapred/org/apache/hadoop/mapred/TaskTracker.java?rev=1415848&r1=1415847&r2=1415848&view=diff
==============================================================================
---
hadoop/common/branches/branch-1/src/mapred/org/apache/hadoop/mapred/TaskTracker.java
(original)
+++
hadoop/common/branches/branch-1/src/mapred/org/apache/hadoop/mapred/TaskTracker.java
Fri Nov 30 20:46:14 2012
@@ -1734,6 +1734,11 @@ public class TaskTracker implements MRCo
// accelerate to account for multiple finished tasks up-front
long remaining =
(lastHeartbeat + getHeartbeatInterval(finishedCount.get())) - now;
+
+ if (remaining <= 0) {
+ finishedCount.set(0);
+ }
+
while (remaining > 0) {
// sleeps for the wait time or
// until there are *enough* empty slots to schedule tasks
