Here its showing like you are not using mapreduce.framework.name as yarn, please resend it we are unable to see the configuration
On Wed, Jul 10, 2013 at 1:33 AM, Francis.Hu <francis...@reachjunction.com>wrote: > Hi,All**** > > ** ** > > I have a hadoop- 2.0.5-alpha cluster with 3 data nodes . I have Resource > Manager and all data nodes started and can access web ui of Resource > Manager. **** > > I wrote a java client to submit a job as TestJob class below. But the job > is never submitted successfully. It throws out exception all the time. *** > * > > My configurations are attached. Can anyone help me? Thanks.**** > > ** ** > > ---------my-java client**** > > *public* *class* TestJob {**** > > **** > > *public* *void* execute() {**** > > ** ** > > Configuration conf1 = *new* Configuration();**** > > conf1.addResource("resources/core-site.xml");**** > > conf1.addResource("resources/hdfs-site.xml");**** > > conf1.addResource("resources/yarn-site.xml");**** > > conf1.addResource("resources/mapred-site.xml");**** > > JobConf conf = *new* JobConf(conf1);**** > > **** > > conf.setJar("/home/francis/hadoop-jobs/MapReduceJob.jar");**** > > conf.setJobName("Test");**** > > ** ** > > conf.setInputFormat(TextInputFormat.*class*);**** > > conf.setOutputFormat(TextOutputFormat.*class*);**** > > ** ** > > conf.setOutputKeyClass(Text.*class*);**** > > conf.setOutputValueClass(IntWritable.*class*);**** > > ** ** > > conf.setMapperClass(DisplayRequestMapper.*class*);**** > > conf.setReducerClass(DisplayRequestReducer.*class*);**** > > ** ** > > FileInputFormat.*setInputPaths*(conf,*new* Path( > "/home/francis/hadoop-jobs/2013070907.FNODE.2.txt"));**** > > FileOutputFormat.*setOutputPath*(conf, *new* Path( > "/home/francis/hadoop-jobs/result/"));**** > > ** ** > > *try* {**** > > JobClient client = *new* JobClient(conf);**** > > RunningJob job = client.submitJob(conf);**** > > job.waitForCompletion();**** > > } *catch* (IOException e) {**** > > e.printStackTrace();**** > > }**** > > }**** > > }**** > > ** ** > > ----------Exception **** > > ** ** > > jvm 1 | java.io.IOException: Cannot initialize Cluster. Please check > your configuration for mapreduce.framework.name and the correspond server > addresses.**** > > jvm 1 | at > org.apache.hadoop.mapreduce.Cluster.initialize(Cluster.java:119)**** > > jvm 1 | at > org.apache.hadoop.mapreduce.Cluster.<init>(Cluster.java:81)**** > > jvm 1 | at > org.apache.hadoop.mapreduce.Cluster.<init>(Cluster.java:74)**** > > jvm 1 | at > org.apache.hadoop.mapred.JobClient.init(JobClient.java:482)**** > > jvm 1 | at > org.apache.hadoop.mapred.JobClient.<init>(JobClient.java:461)**** > > jvm 1 | at > com.rh.elastic.hadoop.job.TestJob.execute(TestJob.java:59)**** > > ** ** > > ** ** > > Thanks,**** > > Francis.Hu**** > > ** ** >