Author: edwardyoon
Date: Wed Apr 15 02:01:16 2015
New Revision: 1673614
URL: http://svn.apache.org/r1673614
Log: (empty)
Modified:
hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPJobClient.java
Modified: hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPJobClient.java
URL:
http://svn.apache.org/viewvc/hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPJobClient.java?rev=1673614&r1=1673613&r2=1673614&view=diff
==============================================================================
--- hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPJobClient.java
(original)
+++ hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPJobClient.java Wed Apr
15 02:01:16 2015
@@ -349,8 +349,8 @@ public class BSPJobClient extends Config
// Create the splits for the job
LOG.debug("Creating splits at " + fs.makeQualified(submitSplitFile));
- InputSplit[] splits = job.getInputFormat().getSplits(job, configured);
-
+ InputSplit[] splits = job.getInputFormat().getSplits(job, (maxTasks >
configured) ? configured : maxTasks);
+
if (maxTasks < splits.length) {
throw new IOException(
"Job failed! The number of splits has exceeded the number of max
tasks. The number of splits: "
