You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by as...@apache.org on 2009/03/04 00:21:40 UTC

svn commit: r749836 - /hadoop/core/trunk/src/contrib/chukwa/src/java/org/apache/hadoop/chukwa/datacollection/collector/servlet/ServletCollector.java

Author: asrabkin
Date: Tue Mar  3 23:21:40 2009
New Revision: 749836

URL: http://svn.apache.org/viewvc?rev=749836&view=rev
Log:
HADOOP-5373
Chukwa collectors now track lifetime-received chunks.  (patch by asrabkin)

Modified:
    hadoop/core/trunk/src/contrib/chukwa/src/java/org/apache/hadoop/chukwa/datacollection/collector/servlet/ServletCollector.java

Modified: hadoop/core/trunk/src/contrib/chukwa/src/java/org/apache/hadoop/chukwa/datacollection/collector/servlet/ServletCollector.java
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/chukwa/src/java/org/apache/hadoop/chukwa/datacollection/collector/servlet/ServletCollector.java?rev=749836&r1=749835&r2=749836&view=diff
==============================================================================
--- hadoop/core/trunk/src/contrib/chukwa/src/java/org/apache/hadoop/chukwa/datacollection/collector/servlet/ServletCollector.java (original)
+++ hadoop/core/trunk/src/contrib/chukwa/src/java/org/apache/hadoop/chukwa/datacollection/collector/servlet/ServletCollector.java Tue Mar  3 23:21:40 2009
@@ -53,6 +53,7 @@
 	static long statTime = 0L;
 	static int numberHTTPConnection = 0;
 	static int numberchunks = 0;
+	static long lifetimechunks=0;
 	
 	Configuration conf;
   
@@ -154,6 +155,7 @@
 			{
 				writer.add(events);
 				numberchunks += events.size();
+				lifetimechunks += events.size();
 				//this is where we ACK this connection
 				l_out.print(sb.toString());
 			}
@@ -199,6 +201,7 @@
 		  out.println("Now:" + System.currentTimeMillis());
 		  out.println("numberHTTPConnection:" + ServletCollector.numberHTTPConnection);
 		  out.println("numberchunks:" + ServletCollector.numberchunks);
+      out.println("lifetimechunks:" + ServletCollector.lifetimechunks);
 	  }
 	  else
 	  {