hadoop-common-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cdoug...@apache.org
Subject svn commit: r753043 - in /hadoop/core/branches/branch-0.20: CHANGES.txt src/mapred/org/apache/hadoop/mapred/JobTrackerMetricsInst.java src/mapred/org/apache/hadoop/mapred/TaskTrackerMetricsInst.java
Date Thu, 12 Mar 2009 22:47:11 GMT
Author: cdouglas
Date: Thu Mar 12 22:47:10 2009
New Revision: 753043

URL: http://svn.apache.org/viewvc?rev=753043&view=rev
Log:
HADOOP-5446. Restore TaskTracker metrics.

Modified:
    hadoop/core/branches/branch-0.20/CHANGES.txt
    hadoop/core/branches/branch-0.20/src/mapred/org/apache/hadoop/mapred/JobTrackerMetricsInst.java
    hadoop/core/branches/branch-0.20/src/mapred/org/apache/hadoop/mapred/TaskTrackerMetricsInst.java

Modified: hadoop/core/branches/branch-0.20/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/core/branches/branch-0.20/CHANGES.txt?rev=753043&r1=753042&r2=753043&view=diff
==============================================================================
--- hadoop/core/branches/branch-0.20/CHANGES.txt (original)
+++ hadoop/core/branches/branch-0.20/CHANGES.txt Thu Mar 12 22:47:10 2009
@@ -751,6 +751,8 @@
     of taskIds that the TaskTracker's TaskMemoryManager manages.
     (Amareshwari Sriramadasu via ddas)
  
+    HADOOP-5446. Restore TaskTracker metrics. (cdouglas)
+
 Release 0.19.1 - Unreleased
 
   IMPROVEMENTS

Modified: hadoop/core/branches/branch-0.20/src/mapred/org/apache/hadoop/mapred/JobTrackerMetricsInst.java
URL: http://svn.apache.org/viewvc/hadoop/core/branches/branch-0.20/src/mapred/org/apache/hadoop/mapred/JobTrackerMetricsInst.java?rev=753043&r1=753042&r2=753043&view=diff
==============================================================================
--- hadoop/core/branches/branch-0.20/src/mapred/org/apache/hadoop/mapred/JobTrackerMetricsInst.java
(original)
+++ hadoop/core/branches/branch-0.20/src/mapred/org/apache/hadoop/mapred/JobTrackerMetricsInst.java
Thu Mar 12 22:47:10 2009
@@ -73,26 +73,32 @@
     }
   }
 
+  @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;
   }

Modified: hadoop/core/branches/branch-0.20/src/mapred/org/apache/hadoop/mapred/TaskTrackerMetricsInst.java
URL: http://svn.apache.org/viewvc/hadoop/core/branches/branch-0.20/src/mapred/org/apache/hadoop/mapred/TaskTrackerMetricsInst.java?rev=753043&r1=753042&r2=753043&view=diff
==============================================================================
--- hadoop/core/branches/branch-0.20/src/mapred/org/apache/hadoop/mapred/TaskTrackerMetricsInst.java
(original)
+++ hadoop/core/branches/branch-0.20/src/mapred/org/apache/hadoop/mapred/TaskTrackerMetricsInst.java
Thu Mar 12 22:47:10 2009
@@ -43,23 +43,27 @@
     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 @@
   }
 
   
-}
\ No newline at end of file
+}



Mime
View raw message