package org.slc.sli.stamper.jobs;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.conf.Configured;
import org.apache.hadoop.mapred.JobConf;
import org.apache.hadoop.mapreduce.Job;
import org.apache.hadoop.util.Tool;
import org.apache.hadoop.util.ToolRunner;
import org.slc.sli.stamper.mapreduce.map.ConfigurableMapReduceJob;

public class Stamper extends Configured implements Tool {

    public static void main(String[] args) throws Exception {
        int res = ToolRunner.run(new Configuration(), new Stamper(), args);
        System.exit(res);
    }
	
	@Override
	public int run(String[] args) throws Exception {
		Configuration conf = new Configuration();
		JobConf jobConf = ConfigurableMapReduceJob.parseMapper(conf, "stamper.json");
		Job job = new Job(jobConf);
		boolean success = job.waitForCompletion(true);
		return success ? 0 : 1;
	}

}

@@ -758,16 +758,155 @@
 json%22);%0A
+%09%09jobConf.setNumMapTasks(30);%0A%09%09jobConf.setNumReduceTasks(6);%0A%09%09jobConf.setMemoryForMapTask(4096);%0A%09%09jobConf.setMemoryForReduceTask(8192);%0A
 %09%09Job jo

Increase the number of map/reduce tasks.