svn commit: r941888 - /lucene/mahout/trunk/core/src/main/java/org/apache/mahout/clustering/dirichlet/DirichletDriver.java

[sr...@apache.org]

Author: srowen
Date: Thu May  6 20:04:55 2010
New Revision: 941888

URL: http://svn.apache.org/viewvc?rev=941888&view=rev
Log:
MAHOUT-302 fix

Modified:
    lucene/mahout/trunk/core/src/main/java/org/apache/mahout/clustering/dirichlet/DirichletDriver.java

Modified: lucene/mahout/trunk/core/src/main/java/org/apache/mahout/clustering/dirichlet/DirichletDriver.java
URL: http://svn.apache.org/viewvc/lucene/mahout/trunk/core/src/main/java/org/apache/mahout/clustering/dirichlet/DirichletDriver.java?rev=941888&r1=941887&r2=941888&view=diff
==============================================================================
--- lucene/mahout/trunk/core/src/main/java/org/apache/mahout/clustering/dirichlet/DirichletDriver.java (original)
+++ lucene/mahout/trunk/core/src/main/java/org/apache/mahout/clustering/dirichlet/DirichletDriver.java Thu May  6 20:04:55 2010
@@ -44,7 +44,6 @@ import org.apache.hadoop.mapred.Sequence
 import org.apache.mahout.clustering.Cluster;
 import org.apache.mahout.clustering.WeightedVectorWritable;
 import org.apache.mahout.clustering.dirichlet.models.VectorModelDistribution;
-import org.apache.mahout.clustering.kmeans.KMeansDriver;
 import org.apache.mahout.common.CommandLineUtil;
 import org.apache.mahout.common.commandline.DefaultOptionCreator;
 import org.apache.mahout.math.Vector;
@@ -250,7 +249,7 @@ public class DirichletDriver {
     JobConf job = new JobConf(DirichletDriver.class);
     FileSystem fs = FileSystem.get(output.toUri(), job);
     for (int i = 0; i < numModels; i++) {
-      Path path = new Path(stateIn, "/part-" + i);
+      Path path = new Path(stateIn, "part-" + i);
       SequenceFile.Writer writer = new SequenceFile.Writer(fs, job, path, Text.class, DirichletCluster.class);
       writer.append(new Text(Integer.toString(i)), state.getClusters().get(i));
       writer.close();