You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@chukwa.apache.org by ey...@apache.org on 2009/06/23 00:49:22 UTC
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/
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