Hi,
I am trying out the new api and it doesn't execute the Reducer.. not sure
why it is so.
code snippet:
[code]
Job job = new Job();
job.setJarByClass(HdpTest.class);
FileInputFormat.addInputPath(job, new Path("input"));
FileOutputFormat.setOutputPath(job, new Path("output"));
job.setMapperClass(HdpTest.Map.class);
job.setReducerClass(HdpTest.Reduce.class);
job.getConfiguration().set("mapred.job.tracker", "local");
job.waitForCompletion(true);
[/code]
am i missing something ? I am executing it within eclipse.
