HADOOP-5446. Restore TaskTracker metrics.

git-svn-id: https://svn.apache.org/repos/asf/hadoop/core/branches/branch-0.19@753045 13f79535-47bb-0310-9956-ffa450edef68

CHANGES.txt

@@ -68,6 +68,8 @@ Release 0.19.2 - Unreleased
     HADOOP-5440. Fixes a problem to do with removing a taskId from the list
     of taskIds that the TaskTracker's TaskMemoryManager manages.
     (Amareshwari Sriramadasu via ddas)
+
+    HADOOP-5446. Restore TaskTracker metrics. (cdouglas)
  
 Release 0.19.1 - 2009-02-23
 

src/mapred/org/apache/hadoop/mapred/JobTrackerMetricsInst.java

@@ -73,26 +73,32 @@ class JobTrackerMetricsInst extends JobTrackerInstrumentation implements Updater
     }
   }
 
+  @Override
   public synchronized void launchMap(TaskAttemptID taskAttemptID) {
     ++numMapTasksLaunched;
   }
-    
+
+  @Override
   public synchronized void completeMap(TaskAttemptID taskAttemptID) {
     ++numMapTasksCompleted;
   }
-    
+
+  @Override
   public synchronized void launchReduce(TaskAttemptID taskAttemptID) {
     ++numReduceTasksLaunched;
   }
-    
+
+  @Override
   public synchronized void completeReduce(TaskAttemptID taskAttemptID) {
     ++numReduceTasksCompleted;
   }
-    
+
+  @Override
   public synchronized void submitJob(JobConf conf, JobID id) {
     ++numJobsSubmitted;
   }
-    
+
+  @Override
   public synchronized void completeJob(JobConf conf, JobID id) {
     ++numJobsCompleted;
   }

src/mapred/org/apache/hadoop/mapred/TaskTrackerMetricsInst.java

@@ -43,23 +43,27 @@ class TaskTrackerMetricsInst extends TaskTrackerInstrumentation
     metricsRecord.setTag("sessionId", sessionId);
     context.registerUpdater(this);
   }
-    
-  synchronized void completeTask() {
+
+  @Override
+  public synchronized void completeTask(TaskAttemptID t) {
     ++numCompletedTasks;
   }
-  
-  synchronized void timedoutTask() {
+
+  @Override
+  public synchronized void timedoutTask(TaskAttemptID t) {
     ++timedoutTasks;
   }
-  
-  synchronized void taskFailedPing() {
+
+  @Override
+  public synchronized void taskFailedPing(TaskAttemptID t) {
     ++tasksFailedPing;
   }
-  
+
   /**
    * Since this object is a registered updater, this method will be called
    * periodically, e.g. every 5 seconds.
-   */  
+   */
+  @Override
   public void doUpdates(MetricsContext unused) {
     synchronized (this) {
       metricsRecord.setMetric("maps_running", tt.mapTotal);
@@ -79,4 +83,4 @@ class TaskTrackerMetricsInst extends TaskTrackerInstrumentation
   }
 
   
-}
+}