Index: core/src/main/java/org/apache/hama/bsp/JobInProgress.java =================================================================== --- core/src/main/java/org/apache/hama/bsp/JobInProgress.java (revision 1693001) +++ core/src/main/java/org/apache/hama/bsp/JobInProgress.java (working copy) @@ -266,7 +266,8 @@ + splits.length); // adjust number of BSP tasks to actual number of splits - this.tasks = new TaskInProgress[numBSPTasks]; + int numMaxTasks = Math.max(numBSPTasks, splits.length); + this.tasks = new TaskInProgress[numMaxTasks]; for (int i = 0; i < splits.length; i++) { tasks[i] = new TaskInProgress(getJobID(), this.jobFile.toString(), splits[i], this.conf, this, i);