incubator-hama-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From edwardy...@apache.org
Subject svn commit: r1201665 - in /incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp: BSPJob.java JobInProgress.java
Date Mon, 14 Nov 2011 11:14:42 GMT
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(),



Mime
View raw message