|
@@ -472,6 +472,7 @@ public class TestDFSIO implements Tool {
|
|
job.setOutputKeyClass(Text.class);
|
|
job.setOutputKeyClass(Text.class);
|
|
job.setOutputValueClass(Text.class);
|
|
job.setOutputValueClass(Text.class);
|
|
job.setNumReduceTasks(1);
|
|
job.setNumReduceTasks(1);
|
|
|
|
+ job.setSpeculativeExecution(false);
|
|
JobClient.runJob(job);
|
|
JobClient.runJob(job);
|
|
}
|
|
}
|
|
|
|
|