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