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 {
