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;

Reply via email to