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
{