Author: edwardyoon
Date: Mon Nov 14 11:14:42 2011
New Revision: 1201665
URL: http://svn.apache.org/viewvc?rev=1201665&view=rev
Log:
Set bsp.peer.num to 1 as a default
Modified:
incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPJob.java
incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/JobInProgress.java
Modified:
incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPJob.java
URL:
http://svn.apache.org/viewvc/incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPJob.java?rev=1201665&r1=1201664&r2=1201665&view=diff
==============================================================================
--- incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPJob.java
(original)
+++ incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPJob.java Mon
Nov 14 11:14:42 2011
@@ -230,7 +230,8 @@ public class BSPJob extends BSPJobContex
}
public int getNumBspTask() {
- return conf.getInt("bsp.peers.num", 0);
+ // default is 1, because with zero, we will hang in infinity
+ return conf.getInt("bsp.peers.num", 1);
}
@SuppressWarnings({ "rawtypes" })
Modified:
incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/JobInProgress.java
URL:
http://svn.apache.org/viewvc/incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/JobInProgress.java?rev=1201665&r1=1201664&r2=1201665&view=diff
==============================================================================
---
incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/JobInProgress.java
(original)
+++
incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/JobInProgress.java
Mon Nov 14 11:14:42 2011
@@ -100,8 +100,7 @@ class JobInProgress {
BSPJob job = new BSPJob(jobId, localJobFile.toString());
this.jobSplit = job.getConf().get("bsp.job.split.file");
- // default is 1, because with zero, we will hang in infinity
- this.numBSPTasks = job.getInt("bsp.peers.num", 1);
+ this.numBSPTasks = job.getNumBspTask();
this.profile = new JobProfile(job.getUser(), jobId, jobFile.toString(),
