Skip to content

Add resource to MRJob

Janos Matyas edited this page Mar 14, 2014 · 1 revision

Configuration conf = new Configuration(); conf.set("mapreduce.job.queuename", queueName);

conf.set(MRJobConfig.MAP_CPU_VCORES, "2");
conf.set(MRJobConfig.MAP_MEMORY_MB, "2048"); conf.set(MRJobConfig.REDUCE_CPU_VCORES, "1"); conf.set(MRJobConfig.REDUCE_MEMORY_MB, "1024");

Clone this wiki locally