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.

Reply via email to