chukwa-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ey...@apache.org
Subject svn commit: r787430 - in /hadoop/chukwa: branches/chukwa-0.2/ branches/chukwa-0.2/src/java/org/apache/hadoop/chukwa/extraction/demux/ trunk/ trunk/src/java/org/apache/hadoop/chukwa/extraction/demux/
Date Mon, 22 Jun 2009 22:49:22 GMT
Author: eyang
Date: Mon Jun 22 22:49:22 2009
New Revision: 787430

URL: http://svn.apache.org/viewvc?rev=787430&view=rev
Log:
CHUKWA-327. Removed hourly rolling flag from daily rolling. (Jerome Boulon via Eric Yang)

Modified:
    hadoop/chukwa/branches/chukwa-0.2/CHANGES.txt
    hadoop/chukwa/branches/chukwa-0.2/src/java/org/apache/hadoop/chukwa/extraction/demux/MoveToRepository.java
    hadoop/chukwa/trunk/CHANGES.txt
    hadoop/chukwa/trunk/src/java/org/apache/hadoop/chukwa/extraction/demux/MoveToRepository.java

Modified: hadoop/chukwa/branches/chukwa-0.2/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/chukwa/branches/chukwa-0.2/CHANGES.txt?rev=787430&r1=787429&r2=787430&view=diff
==============================================================================
--- hadoop/chukwa/branches/chukwa-0.2/CHANGES.txt (original)
+++ hadoop/chukwa/branches/chukwa-0.2/CHANGES.txt Mon Jun 22 22:49:22 2009
@@ -70,6 +70,8 @@
 
   BUG FIXES
 
+    CHUKWA-327. Removed hourly rolling flag from daily rolling. (Jerome Boulon via Eric Yang)
+
     CHUKWA-324. For 0 matched field, changed MDL to skip empty SQL statement. (Eric Yang)
 
     CHUKWA-321. Added 2 seconds sleep to avoid chukwa agent race condition. (Eric Yang)

Modified: hadoop/chukwa/branches/chukwa-0.2/src/java/org/apache/hadoop/chukwa/extraction/demux/MoveToRepository.java
URL: http://svn.apache.org/viewvc/hadoop/chukwa/branches/chukwa-0.2/src/java/org/apache/hadoop/chukwa/extraction/demux/MoveToRepository.java?rev=787430&r1=787429&r2=787430&view=diff
==============================================================================
--- hadoop/chukwa/branches/chukwa-0.2/src/java/org/apache/hadoop/chukwa/extraction/demux/MoveToRepository.java
(original)
+++ hadoop/chukwa/branches/chukwa-0.2/src/java/org/apache/hadoop/chukwa/extraction/demux/MoveToRepository.java
Mon Jun 22 22:49:22 2009
@@ -102,8 +102,6 @@
         fileDay = Integer.parseInt(fileName.substring(l - 14, l - 6));
         writeRecordFile(destDir + "/" + fileDay + "/", recordFile.getPath(),
             dataSource + "_" + fileDay);
-        // mark this directory for Daily rotate (re-process)
-        addDirectory4Rolling(true, fileDay, fileHour, cluster, dataSource);
       } else if (fileName.endsWith(".H.evt")) {
         // Hadoop_dfs_datanode_20080925_1.H.evt
         // Hadoop_dfs_datanode_20080925_12.H.evt

Modified: hadoop/chukwa/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/chukwa/trunk/CHANGES.txt?rev=787430&r1=787429&r2=787430&view=diff
==============================================================================
--- hadoop/chukwa/trunk/CHANGES.txt (original)
+++ hadoop/chukwa/trunk/CHANGES.txt Mon Jun 22 22:49:22 2009
@@ -72,6 +72,8 @@
 
   BUG FIXES
 
+    CHUKWA-327. Removed hourly rolling flag from daily rolling. (Jerome Boulon via Eric Yang)
+
     CHUKWA-324. For 0 matched field, changed MDL to skip empty SQL statement. (Eric Yang)
 
     CHUKWA-321. Added 2 seconds sleep to avoid chukwa agent race condition. (Eric Yang)

Modified: hadoop/chukwa/trunk/src/java/org/apache/hadoop/chukwa/extraction/demux/MoveToRepository.java
URL: http://svn.apache.org/viewvc/hadoop/chukwa/trunk/src/java/org/apache/hadoop/chukwa/extraction/demux/MoveToRepository.java?rev=787430&r1=787429&r2=787430&view=diff
==============================================================================
--- hadoop/chukwa/trunk/src/java/org/apache/hadoop/chukwa/extraction/demux/MoveToRepository.java
(original)
+++ hadoop/chukwa/trunk/src/java/org/apache/hadoop/chukwa/extraction/demux/MoveToRepository.java
Mon Jun 22 22:49:22 2009
@@ -102,8 +102,6 @@
         fileDay = Integer.parseInt(fileName.substring(l - 14, l - 6));
         writeRecordFile(destDir + "/" + fileDay + "/", recordFile.getPath(),
             dataSource + "_" + fileDay);
-        // mark this directory for Daily rotate (re-process)
-        addDirectory4Rolling(true, fileDay, fileHour, cluster, dataSource);
       } else if (fileName.endsWith(".H.evt")) {
         // Hadoop_dfs_datanode_20080925_1.H.evt
         // Hadoop_dfs_datanode_20080925_12.H.evt



Mime
View raw message