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
{
