svn commit: r1430113 - /hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPJob.java

[edwardyoon]

Author: edwardyoon
Date: Tue Jan  8 02:06:25 2013
New Revision: 1430113

URL: http://svn.apache.org/viewvc?rev=1430113&view=rev
Log:
Fix minor bug

Modified:
    hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPJob.java

Modified: hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPJob.java
URL: 
http://svn.apache.org/viewvc/hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPJob.java?rev=1430113&r1=1430112&r2=1430113&view=diff
==============================================================================
--- hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPJob.java (original)
+++ hama/trunk/core/src/main/java/org/apache/hama/bsp/BSPJob.java Tue Jan  8 
02:06:25 2013
@@ -240,7 +240,7 @@ public class BSPJob extends BSPJobContex
       HamaConfiguration conf = new HamaConfiguration();
       conf.setInt("desired.num.of.tasks",
           Integer.parseInt(this.getConfiguration().get("bsp.peers.num")));
-      if(conf.get("bsp.partitioning.dir") != null) {
+      if(this.getConfiguration().get("bsp.partitioning.dir") != null) {
         conf.set("bsp.partitioning.dir", 
this.getConfiguration().get("bsp.partitioning.dir"));
        }
       BSPJob partitioningJob = new BSPJob(conf);