hadoop-common-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cdoug...@apache.org
Subject svn commit: r742792 - in /hadoop/core/trunk: CHANGES.txt src/contrib/chukwa/src/java/org/apache/hadoop/chukwa/extraction/demux/DailyChukwaRecordRolling.java
Date Tue, 10 Feb 2009 00:00:12 GMT
Author: cdouglas
Date: Tue Feb 10 00:00:12 2009
New Revision: 742792

URL: http://svn.apache.org/viewvc?rev=742792&view=rev
Log:
HADOOP-4859. Distinguish daily rolling output dir by adding a timestamp. Contributed by Jerome
Boulon

Modified:
    hadoop/core/trunk/CHANGES.txt
    hadoop/core/trunk/src/contrib/chukwa/src/java/org/apache/hadoop/chukwa/extraction/demux/DailyChukwaRecordRolling.java

Modified: hadoop/core/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/CHANGES.txt?rev=742792&r1=742791&r2=742792&view=diff
==============================================================================
--- hadoop/core/trunk/CHANGES.txt (original)
+++ hadoop/core/trunk/CHANGES.txt Tue Feb 10 00:00:12 2009
@@ -114,6 +114,9 @@
 
     HADOOP-5176. Fix a typo in TestDFSIO.  (Ravi Phulari via szetszwo)
 
+    HADOOP-4859. Distinguish daily rolling output dir by adding a timestamp.
+    (Jerome Boulon via cdouglas)
+
 Release 0.20.0 - Unreleased
 
   INCOMPATIBLE CHANGES

Modified: hadoop/core/trunk/src/contrib/chukwa/src/java/org/apache/hadoop/chukwa/extraction/demux/DailyChukwaRecordRolling.java
URL: http://svn.apache.org/viewvc/hadoop/core/trunk/src/contrib/chukwa/src/java/org/apache/hadoop/chukwa/extraction/demux/DailyChukwaRecordRolling.java?rev=742792&r1=742791&r2=742792&view=diff
==============================================================================
--- hadoop/core/trunk/src/contrib/chukwa/src/java/org/apache/hadoop/chukwa/extraction/demux/DailyChukwaRecordRolling.java
(original)
+++ hadoop/core/trunk/src/contrib/chukwa/src/java/org/apache/hadoop/chukwa/extraction/demux/DailyChukwaRecordRolling.java
Tue Feb 10 00:00:12 2009
@@ -90,7 +90,7 @@
 				// input
 				mergeArgs[0] = chukwaMainRepository + "/" + cluster + "/" + dataSource + "/" + workingDay
+  "/*/*.evt";
 				// temp dir
-				mergeArgs[1] = tempDir + "/" + cluster + "/" + dataSource + "/" + workingDay ;
+				mergeArgs[1] = tempDir + "/" + cluster + "/" + dataSource + "/" + workingDay + "_" +
System.currentTimeMillis();
 				// final output dir
 				mergeArgs[2] = chukwaMainRepository + "/" + cluster + "/" + dataSource + "/" + workingDay
 ;
 				// final output fileName



Mime
View raw message