svn commit: r1170629 - /mahout/trunk/integration/src/main/java/org/apache/mahout/text/ChunkedWriter.java

[srowen]

Author: srowen
Date: Wed Sep 14 14:00:25 2011
New Revision: 1170629

URL: http://svn.apache.org/viewvc?rev=1170629&view=rev
Log:
MAHOUT-809 avoid overwriting prior chunk when updating to next writer

Modified:
    
mahout/trunk/integration/src/main/java/org/apache/mahout/text/ChunkedWriter.java

Modified: 
mahout/trunk/integration/src/main/java/org/apache/mahout/text/ChunkedWriter.java
URL: 
http://svn.apache.org/viewvc/mahout/trunk/integration/src/main/java/org/apache/mahout/text/ChunkedWriter.java?rev=1170629&r1=1170628&r2=1170629&view=diff
==============================================================================
--- 
mahout/trunk/integration/src/main/java/org/apache/mahout/text/ChunkedWriter.java
 (original)
+++ 
mahout/trunk/integration/src/main/java/org/apache/mahout/text/ChunkedWriter.java
 Wed Sep 14 14:00:25 2011
@@ -55,7 +55,8 @@ public final class ChunkedWriter impleme
   public void write(String key, String value) throws IOException {
     if (currentChunkSize > maxChunkSizeInBytes) {
       Closeables.closeQuietly(writer);
-      writer = new SequenceFile.Writer(fs, conf, getPath(currentChunkID++), 
Text.class, Text.class);
+      currentChunkID++;
+      writer = new SequenceFile.Writer(fs, conf, getPath(currentChunkID), 
Text.class, Text.class);
       currentChunkSize = 0;
     }