chukwa-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ey...@apache.org
Subject svn commit: r934482 - /hadoop/chukwa/trunk/src/java/org/apache/hadoop/chukwa/extraction/demux/PostProcessorManager.java
Date Thu, 15 Apr 2010 16:42:09 GMT
Author: eyang
Date: Thu Apr 15 16:42:09 2010
New Revision: 934482

URL: http://svn.apache.org/viewvc?rev=934482&view=rev
Log:
CHUKWA-465. Setup default value for Post Demux Data Loader.  (Ahmed Fathalla via Eric Yang)

Modified:
    hadoop/chukwa/trunk/src/java/org/apache/hadoop/chukwa/extraction/demux/PostProcessorManager.java

Modified: hadoop/chukwa/trunk/src/java/org/apache/hadoop/chukwa/extraction/demux/PostProcessorManager.java
URL: http://svn.apache.org/viewvc/hadoop/chukwa/trunk/src/java/org/apache/hadoop/chukwa/extraction/demux/PostProcessorManager.java?rev=934482&r1=934481&r2=934482&view=diff
==============================================================================
--- hadoop/chukwa/trunk/src/java/org/apache/hadoop/chukwa/extraction/demux/PostProcessorManager.java
(original)
+++ hadoop/chukwa/trunk/src/java/org/apache/hadoop/chukwa/extraction/demux/PostProcessorManager.java
Thu Apr 15 16:42:09 2010
@@ -170,7 +170,7 @@ public class PostProcessorManager implem
   public boolean processDemuxPigOutput(String directory) throws IOException {
     long start = System.currentTimeMillis();
     try {
-      String[] classes = conf.get(POST_DEMUX_DATA_LOADER).split(",");
+      String[] classes = conf.get(POST_DEMUX_DATA_LOADER,"org.apache.hadoop.chukwa.dataloader.MetricDataLoaderPool,org.apache.hadoop.chukwa.dataloader.FSMDataLoader").split(",");
       for(String dataLoaderName : classes) {
         Class<? extends DataLoaderFactory> dl = (Class<? extends DataLoaderFactory>)
Class.forName(dataLoaderName);
         java.lang.reflect.Constructor<? extends DataLoaderFactory> c =



Mime
View raw message