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

[edwardyoon]

Author: edwardyoon
Date: Sun May 17 22:59:31 2015
New Revision: 1679906

URL: http://svn.apache.org/r1679906
Log:
graphjob uses own vertx partitioning.

Modified:
    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/bsp/BSPJobClient.java
URL: 
http://svn.apache.org/viewvc/hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPJobClient.java?rev=1679906&r1=1679905&r2=1679906&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 Sun May 
17 22:59:31 2015
@@ -354,6 +354,7 @@ public class BSPJobClient extends Config
 
       if (job.getConfiguration().getBoolean(
           Constants.ENABLE_RUNTIME_PARTITIONING, false)) {
+        LOG.info("Run pre-partitioning job");
         job = partition(job, splits, maxTasks);
         maxTasks = job.getInt("hama.partition.count", maxTasks);
       }

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=1679906&r1=1679905&r2=1679906&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 Sun May 
17 22:59:31 2015
@@ -59,6 +59,7 @@ public class GraphJob extends BSPJob {
     conf.setClass(MessageManager.OUTGOING_MESSAGE_MANAGER_CLASS,
         OutgoingVertexMessageManager.class, OutgoingMessageManager.class);
     conf.setBoolean(Constants.FORCE_SET_BSP_TASKS, true);
+    conf.setBoolean(Constants.ENABLE_RUNTIME_PARTITIONING, false);
     
     this.setBspClass(GraphJobRunner.class);
     this.setJarByClass(exampleClass);