svn commit: r750578 - in /hadoop/core/trunk/src/contrib/chukwa: ./ src/java/org/apache/hadoop/chukwa/datacollection/agent/ src/test/org/apache/hadoop/chukwa/datacollection/adaptor/filetailer/ src/test/org/apache/hadoop/chukwa/datacollection/agent/

[asrabkin]

Author: asrabkin
Date: Thu Mar  5 20:38:31 2009
New Revision: 750578

URL: http://svn.apache.org/viewvc?rev=750578&view=rev
Log:
HADOOP-5401. Standardize name of agent control port option.

Modified:
    hadoop/core/trunk/src/contrib/chukwa/CHANGES.txt
    
hadoop/core/trunk/src/contrib/chukwa/src/java/org/apache/hadoop/chukwa/datacollection/agent/AgentControlSocketListener.java
    
hadoop/core/trunk/src/contrib/chukwa/src/test/org/apache/hadoop/chukwa/datacollection/adaptor/filetailer/TestFileTailingAdaptorBigRecord.java
    
hadoop/core/trunk/src/contrib/chukwa/src/test/org/apache/hadoop/chukwa/datacollection/agent/TestAgentConfig.java

Modified: hadoop/core/trunk/src/contrib/chukwa/CHANGES.txt
URL: 
http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/chukwa/CHANGES.txt?rev=750578&r1=750577&r2=750578&view=diff
==============================================================================
--- hadoop/core/trunk/src/contrib/chukwa/CHANGES.txt (original)
+++ hadoop/core/trunk/src/contrib/chukwa/CHANGES.txt Thu Mar  5 20:38:31 2009
@@ -5,7 +5,12 @@
   NEW FEATURES
 
   IMPROVEMENTS
+    
+    HADOOP-5373   Collectors track lifetime-received chunks. (asrabkin)
 
+    HADOOP-5370   Collectors don't write empty sink files (asrabkin)
+
+       
   OPTIMIZATIONS
 
   BUG FIXES
@@ -13,6 +18,12 @@
     HADOOP-5138. Fixing failing test cases by separating TestCharFileTailing
     and TestFileTailing adaptors. (Jerome Boulon via acmurthy)
 
+    HADOOP-5401. Standardize control port conf option name as 
chukwaAgent.control.port (asrabkin)
+
+    HADOOP-5087. Fix regex for command parsing. (asrabkin)
+
+    HADOOP-5057. Better test coverage for missing checkpoint cases. (asrabkin)
+
 Release 0.19.0 - Unreleased
 
   IMPROVEMENTS
@@ -27,6 +38,7 @@
 
     HADOOP-5033.  Simplified ChukwaWriter API.  (asrabkin)
 
+
   NEW FEATURES
 
     HADOOP-3719. Initial checkin of Chukwa, which is a data collection and 

Modified: 
hadoop/core/trunk/src/contrib/chukwa/src/java/org/apache/hadoop/chukwa/datacollection/agent/AgentControlSocketListener.java
URL: 
http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/chukwa/src/java/org/apache/hadoop/chukwa/datacollection/agent/AgentControlSocketListener.java?rev=750578&r1=750577&r2=750578&view=diff
==============================================================================
--- 
hadoop/core/trunk/src/contrib/chukwa/src/java/org/apache/hadoop/chukwa/datacollection/agent/AgentControlSocketListener.java
 (original)
+++ 
hadoop/core/trunk/src/contrib/chukwa/src/java/org/apache/hadoop/chukwa/datacollection/agent/AgentControlSocketListener.java
 Thu Mar  5 20:38:31 2009
@@ -177,7 +177,7 @@
 
     this.setDaemon(false); // to keep the local agent alive
     this.agent = agent;
-    this.portno = 
agent.getConfiguration().getInt("chukwaAgent.agent.control.port", 9093);
+    this.portno = agent.getConfiguration().getInt("chukwaAgent.control.port", 
9093);
     log.info("AgentControlSocketListerner ask for port: " + portno);
     this.setName("control socket listener");
   }

Modified: 
hadoop/core/trunk/src/contrib/chukwa/src/test/org/apache/hadoop/chukwa/datacollection/adaptor/filetailer/TestFileTailingAdaptorBigRecord.java
URL: 
http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/chukwa/src/test/org/apache/hadoop/chukwa/datacollection/adaptor/filetailer/TestFileTailingAdaptorBigRecord.java?rev=750578&r1=750577&r2=750578&view=diff
==============================================================================
--- 
hadoop/core/trunk/src/contrib/chukwa/src/test/org/apache/hadoop/chukwa/datacollection/adaptor/filetailer/TestFileTailingAdaptorBigRecord.java
 (original)
+++ 
hadoop/core/trunk/src/contrib/chukwa/src/test/org/apache/hadoop/chukwa/datacollection/adaptor/filetailer/TestFileTailingAdaptorBigRecord.java
 Thu Mar  5 20:38:31 2009
@@ -33,7 +33,7 @@
 
       // Remove any adaptor left over from previous run
       ChukwaConfiguration cc = new ChukwaConfiguration();
-      cc.set("chukwaAgent.agent.control.port", "0");
+      cc.set("chukwaAgent.control.port", "0");
       cc.setInt("chukwaAgent.fileTailingAdaptor.maxReadSize", 55);
       ChukwaAgent agent = new ChukwaAgent(cc);
       int portno = agent.getControllerPort();

Modified: 
hadoop/core/trunk/src/contrib/chukwa/src/test/org/apache/hadoop/chukwa/datacollection/agent/TestAgentConfig.java
URL: 
http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/chukwa/src/test/org/apache/hadoop/chukwa/datacollection/agent/TestAgentConfig.java?rev=750578&r1=750577&r2=750578&view=diff
==============================================================================
--- 
hadoop/core/trunk/src/contrib/chukwa/src/test/org/apache/hadoop/chukwa/datacollection/agent/TestAgentConfig.java
 (original)
+++ 
hadoop/core/trunk/src/contrib/chukwa/src/test/org/apache/hadoop/chukwa/datacollection/agent/TestAgentConfig.java
 Thu Mar  5 20:38:31 2009
@@ -88,7 +88,7 @@
       Configuration conf = new Configuration();
       conf.set("chukwaAgent.checkpoint.dir", NONCE_DIR.getAbsolutePath());
       conf.setBoolean("chukwaAgent.checkpoint.enabled", true);
-      conf.setInt("chukwaAgent.agent.control.port", 0);
+      conf.setInt("chukwaAgent.control.port", 0);
       
       System.out.println("\n\n===checkpoints enabled, dir does not exist:");
       ChukwaAgent agent = new ChukwaAgent(conf);