svn commit: r801406 - in /hadoop/chukwa/trunk: CHANGES.txt src/java/org/apache/hadoop/chukwa/datacollection/adaptor/ExecAdaptor.java

[as...@apache.org]

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) {