chukwa-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From asrab...@apache.org
Subject svn commit: r801406 - in /hadoop/chukwa/trunk: CHANGES.txt src/java/org/apache/hadoop/chukwa/datacollection/adaptor/ExecAdaptor.java
Date Wed, 05 Aug 2009 20:37:49 GMT
Author: asrabkin
Date: Wed Aug  5 20:37:48 2009
New Revision: 801406

URL: http://svn.apache.org/viewvc?rev=801406&view=rev
Log:
CHUKWA-370.  Exec adaptor should commit immediately.

Modified:
    hadoop/chukwa/trunk/CHANGES.txt
    hadoop/chukwa/trunk/src/java/org/apache/hadoop/chukwa/datacollection/adaptor/ExecAdaptor.java

Modified: hadoop/chukwa/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/chukwa/trunk/CHANGES.txt?rev=801406&r1=801405&r2=801406&view=diff
==============================================================================
--- hadoop/chukwa/trunk/CHANGES.txt (original)
+++ hadoop/chukwa/trunk/CHANGES.txt Wed Aug  5 20:37:48 2009
@@ -46,6 +46,8 @@
 
   IMPROVEMENTS
 
+    CHUKWA-370.  Exec adaptor should commit immediately. (asrabkin)
+
     CHUKWA-367.  Print metadata in DumpChunks. (asrabkin)
 
     CHUKWA-74.  Agent shouldn't log exceptions for down collectors. (Rushin Barot via asrabkin)

Modified: hadoop/chukwa/trunk/src/java/org/apache/hadoop/chukwa/datacollection/adaptor/ExecAdaptor.java
URL: http://svn.apache.org/viewvc/hadoop/chukwa/trunk/src/java/org/apache/hadoop/chukwa/datacollection/adaptor/ExecAdaptor.java?rev=801406&r1=801405&r2=801406&view=diff
==============================================================================
--- hadoop/chukwa/trunk/src/java/org/apache/hadoop/chukwa/datacollection/adaptor/ExecAdaptor.java
(original)
+++ hadoop/chukwa/trunk/src/java/org/apache/hadoop/chukwa/datacollection/adaptor/ExecAdaptor.java
Wed Aug  5 20:37:48 2009
@@ -104,6 +104,8 @@
         } // else we get default one record
 
         dest.add(c);
+        //We can't replay exec data, so we might as well commit to it now.
+        control.reportCommit(ExecAdaptor.this, sendOffset);
       } catch (JSONException e) {
         log.warn(e);
       } catch (InterruptedException e) {



Mime
View raw message