You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@chukwa.apache.org by as...@apache.org on 2010/03/10 23:45:57 UTC
svn commit: r921606 - in /hadoop/chukwa/trunk: CHANGES.txt
src/java/org/apache/hadoop/chukwa/extraction/demux/MoveToRepository.java
Author: asrabkin
Date: Wed Mar 10 22:45:56 2010
New Revision: 921606
URL: http://svn.apache.org/viewvc?rev=921606&view=rev
Log:
CHUKWA-464. Fix spelling of processClusterDirectory. Contributed by Guillermo Perez.
Modified:
hadoop/chukwa/trunk/CHANGES.txt
hadoop/chukwa/trunk/src/java/org/apache/hadoop/chukwa/extraction/demux/MoveToRepository.java
Modified: hadoop/chukwa/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/chukwa/trunk/CHANGES.txt?rev=921606&r1=921605&r2=921606&view=diff
==============================================================================
--- hadoop/chukwa/trunk/CHANGES.txt (original)
+++ hadoop/chukwa/trunk/CHANGES.txt Wed Mar 10 22:45:56 2010
@@ -62,6 +62,8 @@ Trunk (unreleased changes)
BUG FIXES
+ CHUKWA-464. Fix spelling of processClusterDirectory. (Guillermo Perez via asrabkin)
+
CHUKWA-456. Fixed failing unit test. (Eric Yang)
CHUKWA-455. Updated slaves.sh to detect collectors list. (Guillermo Pérez)
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=921606&r1=921605&r2=921606&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 Wed Mar 10 22:45:56 2010
@@ -44,9 +44,9 @@ public class MoveToRepository {
static SimpleDateFormat sdf = new java.text.SimpleDateFormat("yyyyMMdd");
static Calendar calendar = Calendar.getInstance();
- static void processClutserDirectory(Path srcDir, String destDir)
+ static void processClusterDirectory(Path srcDir, String destDir)
throws Exception {
- log.info("processClutserDirectory (" + srcDir.getName() + "," + destDir
+ log.info("processClusterDirectory (" + srcDir.getName() + "," + destDir
+ ")");
FileStatus fstat = fs.getFileStatus(srcDir);
@@ -67,7 +67,7 @@ public class MoveToRepository {
String dirName = datasourceDirectory.getPath().getName();
Path destPath = new Path(destDir + "/" + dirName);
log.info("dest directory path: " + destPath);
- log.info("processClutserDirectory processing Datasource: (" + dirName
+ log.info("processClusterDirectory processing Datasource: (" + dirName
+ ")");
processDatasourceDirectory(srcDir.getName(), datasourceDirectory
.getPath(), destDir + "/" + dirName);
@@ -247,7 +247,7 @@ public class MoveToRepository {
log
.info("main procesing Cluster (" + cluster.getPath().getName()
+ ")");
- processClutserDirectory(cluster.getPath(), destDir + "/"
+ processClusterDirectory(cluster.getPath(), destDir + "/"
+ cluster.getPath().getName());
// Delete the demux's cluster dir