svn commit: r1679342 - /hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPJobClient.java

[edwardyoon]

Author: edwardyoon
Date: Thu May 14 11:28:07 2015
New Revision: 1679342

URL: http://svn.apache.org/r1679342
Log:
Fix custom partition path

Modified:
    hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPJobClient.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=1679342&r1=1679341&r2=1679342&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 11:28:07 2015
@@ -453,8 +453,8 @@ public class BSPJobClient extends Config
         HamaConfiguration conf = new HamaConfiguration(job.getConfiguration());
 
         if (job.getConfiguration().get(Constants.RUNTIME_PARTITIONING_DIR) != 
null) {
-          conf.set(Constants.RUNTIME_PARTITIONING_DIR, job.getConfiguration()
-              .get(Constants.RUNTIME_PARTITIONING_DIR));
+          partitionDir = new Path(job.getConfiguration().get(
+              Constants.RUNTIME_PARTITIONING_DIR));
         }
 
         conf.set(Constants.RUNTIME_PARTITIONING_CLASS,
@@ -465,13 +465,6 @@ public class BSPJobClient extends Config
         LOG.debug("partitioningJob input: "
             + partitioningJob.get(Constants.JOB_INPUT_DIR));
 
-        partitioningJob.getConfiguration().setClass(
-            MessageManager.OUTGOING_MESSAGE_MANAGER_CLASS,
-            OutgoingPOJOMessageBundle.class, OutgoingMessageManager.class);
-        partitioningJob.getConfiguration().setClass(
-            MessageManager.RECEIVE_QUEUE_TYPE_CLASS, MemoryQueue.class,
-            MessageQueue.class);
-
         partitioningJob.setBoolean(Constants.FORCE_SET_BSP_TASKS, true);
         partitioningJob.setInputFormat(job.getInputFormat().getClass());
         partitioningJob.setInputKeyClass(job.getInputKeyClass());