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

[edwardyoon]

Author: edwardyoon
Date: Tue Dec 18 07:01:53 2012
New Revision: 1423297

URL: http://svn.apache.org/viewvc?rev=1423297&view=rev
Log:
HAMA-531: Fix build failure

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=1423297&r1=1423296&r2=1423297&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 Dec 18 
07:01:53 2012
@@ -240,7 +240,9 @@ public class BSPJob extends BSPJobContex
       HamaConfiguration conf = new HamaConfiguration();
       conf.setInt("desired.num.of.tasks",
           Integer.parseInt(this.getConfiguration().get("bsp.peers.num")));
-      conf.set("bsp.partitioning.dir", 
this.getConfiguration().get("bsp.partitioning.dir"));
+      if(conf.get("bsp.partitioning.dir") != null) {
+        conf.set("bsp.partitioning.dir", 
this.getConfiguration().get("bsp.partitioning.dir"));
+       }
       BSPJob partitioningJob = new BSPJob(conf);
       partitioningJob.setInputPath(new Path(this.getConfiguration().get(
           "bsp.input.dir")));