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());