You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@hama.apache.org by ed...@apache.org on 2012/11/15 01:22:14 UTC

svn commit: r1409609 - /hama/trunk/core/src/main/java/org/apache/hama/bsp/FileInputFormat.java

Author: edwardyoon
Date: Thu Nov 15 00:22:13 2012
New Revision: 1409609

URL: http://svn.apache.org/viewvc?rev=1409609&view=rev
Log:
small patch

Modified:
    hama/trunk/core/src/main/java/org/apache/hama/bsp/FileInputFormat.java

Modified: hama/trunk/core/src/main/java/org/apache/hama/bsp/FileInputFormat.java
URL: http://svn.apache.org/viewvc/hama/trunk/core/src/main/java/org/apache/hama/bsp/FileInputFormat.java?rev=1409609&r1=1409608&r2=1409609&view=diff
==============================================================================
--- hama/trunk/core/src/main/java/org/apache/hama/bsp/FileInputFormat.java (original)
+++ hama/trunk/core/src/main/java/org/apache/hama/bsp/FileInputFormat.java Thu Nov 15 00:22:13 2012
@@ -272,7 +272,8 @@ public abstract class FileInputFormat<K,
   }
 
   protected long computeGoalSize(int numSplits, long totalSize) {
-    return totalSize / (numSplits == 0 ? 1 : numSplits);
+    // The minus 1 is for the remainder.
+    return totalSize / (numSplits <= 1 ? 1 : numSplits - 1);
   }
 
   protected long computeSplitSize(long goalSize, long minSize, long blockSize) {