svn commit: r1679305 - in /hama/trunk: core/src/main/java/org/apache/hama/Constants.java core/src/main/java/org/apache/hama/bsp/BSPJobClient.java graph/src/main/java/org/apache/hama/graph/GraphJob.java

[edwardyoon]

Author: edwardyoon
Date: Thu May 14 03:22:23 2015
New Revision: 1679305

URL: http://svn.apache.org/r1679305
Log:
Minor changes

Modified:
    hama/trunk/core/src/main/java/org/apache/hama/Constants.java
    hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPJobClient.java
    hama/trunk/graph/src/main/java/org/apache/hama/graph/GraphJob.java

Modified: hama/trunk/core/src/main/java/org/apache/hama/Constants.java
URL: 
http://svn.apache.org/viewvc/hama/trunk/core/src/main/java/org/apache/hama/Constants.java?rev=1679305&r1=1679304&r2=1679305&view=diff
==============================================================================
--- hama/trunk/core/src/main/java/org/apache/hama/Constants.java (original)
+++ hama/trunk/core/src/main/java/org/apache/hama/Constants.java Thu May 14 
03:22:23 2015
@@ -128,9 +128,11 @@ public interface Constants {
   public static final String RUNTIME_PARTITIONING_CLASS = 
"bsp.input.partitioner.class";
   public static final String RUNTIME_DESIRED_PEERS_COUNT = 
"desired.num.of.tasks";
   public static final String RUNTIME_PARTITION_RECORDCONVERTER = 
"bsp.runtime.partition.recordconverter";
-
   public static final String PARTITION_SORT_BY_KEY = 
"bsp.partition.sort.by.converted.record";
 
+  // If true, framework launches the number of tasks by user settings.
+  public static final String FORCE_SET_BSP_TASKS = "hama.force.set.bsp.tasks";
+  
   // /////////////////////////////////////
   // Constants for ZooKeeper
   // /////////////////////////////////////

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=1679305&r1=1679304&r2=1679305&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 Thu May 
14 03:22:23 2015
@@ -364,8 +364,7 @@ public class BSPJobClient extends Config
       
       int numOfSplits = writeSplits(job, splits, submitSplitFile, maxTasks);
       if (numOfSplits > configured
-          || !job.getConfiguration().getBoolean("hama.force.set.bsp.tasks",
-              false)) {
+          || !job.getConfiguration().getBoolean(Constants.FORCE_SET_BSP_TASKS, 
false)) {
         job.setNumBspTask(numOfSplits);
       }
 

Modified: hama/trunk/graph/src/main/java/org/apache/hama/graph/GraphJob.java
URL: 
http://svn.apache.org/viewvc/hama/trunk/graph/src/main/java/org/apache/hama/graph/GraphJob.java?rev=1679305&r1=1679304&r2=1679305&view=diff
==============================================================================
--- hama/trunk/graph/src/main/java/org/apache/hama/graph/GraphJob.java 
(original)
+++ hama/trunk/graph/src/main/java/org/apache/hama/graph/GraphJob.java Thu May 
14 03:22:23 2015
@@ -58,7 +58,7 @@ public class GraphJob extends BSPJob {
     super(conf);
     conf.setClass(MessageManager.OUTGOING_MESSAGE_MANAGER_CLASS,
         OutgoingVertexMessageManager.class, OutgoingMessageManager.class);
-    conf.setBoolean("hama.bsp.force.set.tasks", true);
+    conf.setBoolean(Constants.FORCE_SET_BSP_TASKS, true);
     
     this.setBspClass(GraphJobRunner.class);
     this.setJarByClass(exampleClass);