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
