commit 992af3fd111a5e305301475bed195d9992275146
author Edward J. Yoon <edwardyoon@apache.org> Thu May 14 11:28:07 2015 +0000
committer Edward J. Yoon <edwardyoon@apache.org> Thu May 14 11:28:07 2015 +0000
tree b198fc94fbf52d24340f11cfbc57f1a51e41d693
parent 7760fe4431d4a4fc512f233dc233fb79c1e17fa6

Fix custom partition path

git-svn-id: https://svn.apache.org/repos/asf/hama/trunk@1679342 13f79535-47bb-0310-9956-ffa450edef68

core/src/main/java/org/apache/hama/bsp/BSPJobClient.java

diff --git a/core/src/main/java/org/apache/hama/bsp/BSPJobClient.java b/core/src/main/java/org/apache/hama/bsp/BSPJobClient.java
index b626453..c77439e 100644
--- a/core/src/main/java/org/apache/hama/bsp/BSPJobClient.java
+++ b/core/src/main/java/org/apache/hama/bsp/BSPJobClient.java
@@ -453,8 +453,8 @@
         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 @@
         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());