فهرست منبع

HADOOP-4859. Distinguish daily rolling output dir by adding a timestamp. Contributed by Jerome Boulon

git-svn-id: https://svn.apache.org/repos/asf/hadoop/core/trunk@742792 13f79535-47bb-0310-9956-ffa450edef68
Christopher Douglas 16 سال پیش
والد
کامیت
fbf672840b
2فایلهای تغییر یافته به همراه4 افزوده شده و 1 حذف شده
  1. 3 0
      CHANGES.txt
  2. 1 1
      src/contrib/chukwa/src/java/org/apache/hadoop/chukwa/extraction/demux/DailyChukwaRecordRolling.java

+ 3 - 0
CHANGES.txt

@@ -114,6 +114,9 @@ Trunk (unreleased changes)
 
 
     HADOOP-5176. Fix a typo in TestDFSIO.  (Ravi Phulari via szetszwo)
     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
 Release 0.20.0 - Unreleased
 
 
   INCOMPATIBLE CHANGES
   INCOMPATIBLE CHANGES

+ 1 - 1
src/contrib/chukwa/src/java/org/apache/hadoop/chukwa/extraction/demux/DailyChukwaRecordRolling.java

@@ -90,7 +90,7 @@ public class DailyChukwaRecordRolling extends Configured implements Tool
 				// input
 				// input
 				mergeArgs[0] = chukwaMainRepository + "/" + cluster + "/" + dataSource + "/" + workingDay +  "/*/*.evt";
 				mergeArgs[0] = chukwaMainRepository + "/" + cluster + "/" + dataSource + "/" + workingDay +  "/*/*.evt";
 				// temp dir
 				// temp dir
-				mergeArgs[1] = tempDir + "/" + cluster + "/" + dataSource + "/" + workingDay ;
+				mergeArgs[1] = tempDir + "/" + cluster + "/" + dataSource + "/" + workingDay + "_" + System.currentTimeMillis();
 				// final output dir
 				// final output dir
 				mergeArgs[2] = chukwaMainRepository + "/" + cluster + "/" + dataSource + "/" + workingDay  ;
 				mergeArgs[2] = chukwaMainRepository + "/" + cluster + "/" + dataSource + "/" + workingDay  ;
 				// final output fileName
 				// final output fileName