You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mahout.apache.org by sr...@apache.org on 2011/09/14 11:21:50 UTC
svn commit: r1170494 -
/mahout/trunk/integration/src/main/java/org/apache/mahout/text/PrefixAdditionFilter.java
Author: srowen
Date: Wed Sep 14 09:21:50 2011
New Revision: 1170494
URL: http://svn.apache.org/viewvc?rev=1170494&view=rev
Log:
MAHOUT-807 fix recursion
Modified:
mahout/trunk/integration/src/main/java/org/apache/mahout/text/PrefixAdditionFilter.java
Modified: mahout/trunk/integration/src/main/java/org/apache/mahout/text/PrefixAdditionFilter.java
URL: http://svn.apache.org/viewvc/mahout/trunk/integration/src/main/java/org/apache/mahout/text/PrefixAdditionFilter.java?rev=1170494&r1=1170493&r2=1170494&view=diff
==============================================================================
--- mahout/trunk/integration/src/main/java/org/apache/mahout/text/PrefixAdditionFilter.java (original)
+++ mahout/trunk/integration/src/main/java/org/apache/mahout/text/PrefixAdditionFilter.java Wed Sep 14 09:21:50 2011
@@ -46,9 +46,8 @@ public final class PrefixAdditionFilter
FileSystem fs = getFs();
ChunkedWriter writer = getWriter();
if (fst.isDir()) {
- fs.listStatus(fst.getPath(),
- new PrefixAdditionFilter(getConf(), getPrefix() + Path.SEPARATOR + current.getName(),
- getOptions(), writer, fs));
+ String dirPath = getPrefix() + Path.SEPARATOR + current.getName() + Path.SEPARATOR + fst.getPath().getName();
+ fs.listStatus(fst.getPath(), new PrefixAdditionFilter(getConf(), dirPath, getOptions(), writer, fs));
} else {
InputStream in = null;
try {