|
@@ -377,6 +377,7 @@ public class HadoopArchives implements Tool {
|
|
|
conf.setReducerClass(HArchivesReducer.class);
|
|
|
conf.setMapOutputKeyClass(IntWritable.class);
|
|
|
conf.setMapOutputValueClass(Text.class);
|
|
|
+ conf.set("hadoop.job.history.user.location", "none");
|
|
|
FileInputFormat.addInputPath(conf, jobDirectory);
|
|
|
//make sure no speculative execution is done
|
|
|
conf.setSpeculativeExecution(false);
|