You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@hama.apache.org by ed...@apache.org on 2014/02/11 12:55:04 UTC

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

Author: edwardyoon
Date: Tue Feb 11 11:55:04 2014
New Revision: 1567071

URL: http://svn.apache.org/r1567071
Log:
Set partitioning job name

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=1567071&r1=1567070&r2=1567071&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 Tue Feb 11 11:55:04 2014
@@ -439,6 +439,8 @@ public class BSPJobClient extends Config
         conf.set(Constants.RUNTIME_PARTITIONING_CLASS,
             job.get(Constants.RUNTIME_PARTITIONING_CLASS));
         BSPJob partitioningJob = new BSPJob(conf);
+        partitioningJob.setJobName("Runtime partitioning job for "
+            + partitioningJob.getJobName());
         LOG.debug("partitioningJob input: "
             + partitioningJob.get(Constants.JOB_INPUT_DIR));
         partitioningJob.setInputFormat(job.getInputFormat().getClass());