hadoop-common-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cdoug...@apache.org
Subject svn commit: r753042 - in /hadoop/core/trunk: CHANGES.txt src/mapred/org/apache/hadoop/mapred/JobTrackerMetricsInst.java src/mapred/org/apache/hadoop/mapred/TaskTrackerMetricsInst.java
Date Thu, 12 Mar 2009 22:45:42 GMT
Author: cdouglas
Date: Thu Mar 12 22:45:41 2009
New Revision: 753042

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

Modified:
    hadoop/core/trunk/CHANGES.txt
    hadoop/core/trunk/src/mapred/org/apache/hadoop/mapred/JobTrackerMetricsInst.java
    hadoop/core/trunk/src/mapred/org/apache/hadoop/mapred/TaskTrackerMetricsInst.java

Modified: hadoop/core/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/CHANGES.txt?rev=753042&r1=753041&r2=753042&view=diff
==============================================================================
--- hadoop/core/trunk/CHANGES.txt (original)
+++ hadoop/core/trunk/CHANGES.txt Thu Mar 12 22:45:41 2009
@@ -1027,6 +1027,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/trunk/src/mapred/org/apache/hadoop/mapred/JobTrackerMetricsInst.java
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/mapred/org/apache/hadoop/mapred/JobTrackerMetricsInst.java?rev=753042&r1=753041&r2=753042&view=diff
==============================================================================
--- hadoop/core/trunk/src/mapred/org/apache/hadoop/mapred/JobTrackerMetricsInst.java (original)
+++ hadoop/core/trunk/src/mapred/org/apache/hadoop/mapred/JobTrackerMetricsInst.java Thu Mar
12 22:45:41 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/trunk/src/mapred/org/apache/hadoop/mapred/TaskTrackerMetricsInst.java
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/mapred/org/apache/hadoop/mapred/TaskTrackerMetricsInst.java?rev=753042&r1=753041&r2=753042&view=diff
==============================================================================
--- hadoop/core/trunk/src/mapred/org/apache/hadoop/mapred/TaskTrackerMetricsInst.java (original)
+++ hadoop/core/trunk/src/mapred/org/apache/hadoop/mapred/TaskTrackerMetricsInst.java Thu
Mar 12 22:45:41 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