Hello
I m having an issue in running one simple map reduce job.
The portion of the code is below. It gives a warning that Hadoop command
line parsing was not peformed.
This occurs despite the class implements Tool interface. Any clue?
public static void main(String[] args) throws Exception {
try{
int exitcode = ToolRunner.run(new Configuration(), new
MyClass(), args);
System.exit(exitcode);
}
catch(Exception e)
{
e.printStackTrace();
}
}
@Override
public int run(String[] args) throws Exception {
JobConf conf = new JobConf(MyClass.class);
System.out.println(args);
FileInputFormat.addInputPath(conf, new Path("/smallInput"));
conf.setInputFormat(CFNInputFormat.class);
conf.setMapperClass(MyMapper.class);
conf.setMapOutputKeyClass(Text.class);
conf.setMapOutputValueClass(Text.class);
FileOutputFormat.setOutputPath(conf, new Path("/TEST"));
JobClient.runJob(conf);
return 0;