Hi ,

=A0I have a remote server (Cent - = OS - 6.3 ) with CDH-4.0.1 installed.

=A0I do have = another Windows-7.0 machine from which iam trying to submit simple WordCoun= t Map reduce job (i have included the HADOOP - 2.0.0 =A0lib Jars in my Ecli= pse environment)

I am getting the below Exception when i try to run it f= rom ECLIPSE of my Windows7 Machine

//-------------------

Exception in thread "main" java.io.IOException: Cannot ini= tialize Cluster. Please check your configuration for mapreduce.framework.name and the correspond serve= r addresses.

at org.apache.hadoo= p.mapreduce.Cluster.initialize(Cluster.java:121)

at org.apache.hadoop.mapreduce.Cluster.&= lt;init>(Cluster.java:83)

at org.apache.hadoo= p.mapreduce.Cluster.<init>(Cluster.java:76)

at org.apache.hadoop.mapred.JobClient.i= nit(JobClient.java:487)

at org.apache.hadoo= p.mapred.JobClient.<init>(JobClient.java:466)

at org.apache.hadoop.mapred.JobClie= nt.runJob(JobClient.java:879)

at com.pss.WordCoun= t.main(WordCount.java:79)

//-----------------------------------------------------

public class WordCount {

p= ublic static class Map extends MapReduceBase implements Mapper<LongWrita= ble, Text, Text, IntWritable>

{

private final static IntWritab= le one =3D new IntWritable(1);

private Text word =3D new Text();

@Ov= erride

public= void map(LongWritable key, Text value,

OutputCollector<Text, IntWritable> outpu= t, Reporter reporter)

throws IOExcepti= on {

String = line=3Dvalue.toString();

StringTokenizer tokenizer =3D new StringTokenizer(line);

while (tokenizer.= hasMoreTokens())

{

word= .set(tokenizer.nextToken());

output.collect(w= ord, one);

= }

}

=A0 =A0 public static class Reduc= e extends MapReduceBase implements Reducer<Text, IntWritable, Text, IntW= ritable>

=A0 =A0 {

@Override

public void reduce(Text key, Iterator<IntWritable> valu= es,

OutputCollector&= lt;Text, IntWritable> output, Reporter reporter)

throws IOException {

<= span class=3D"" style=3D"white-space:pre"> // TODO Auto-generated = method stub

int sum=3D0;

while(values.hasNext())

{

sum+=3Dvalues.ne= xt().get();

= }

output.col= lect(key, new IntWritable(sum));

}

=A0 = =A0

=A0 =A0 }=

=A0 =A0=A0

=A0 =A0 public static void main(String[] ar= gs) throws IOException {

=A0 =A0 Configurati= on config=3D new Configuration();

=A0 =A0 config.set("fs.default.name","hdfs://xyz-hostname:9000");

=A0 =A0 config.set(= "mapred.job.tracker","xyz-hostname:9001");

= =A0 =A0

=A0 = =A0

=A0 =A0 =A0 =A0 JobConf conf=3D new JobConf(config);

=A0 =A0=

=A0 =A0 conf.setJarByClass(WordCount= .class);

=A0 =A0 =A0 =A0 //conf.setJar(jar);

=A0 =A0

= =A0 =A0 conf.setJobName(= "WordCount");

=A0 =A0 conf.setOutputKeyClass(Text.class);

=A0 =A0 conf.setOut= putValueClass(IntWritable.class);

=A0 =A0

=A0 =A0 conf.setMapperClass(Map.class);

=A0 =A0 //conf.setC= ombinerClass(Reduce.class);

=A0 =A0 conf.setReducerClass(Reduce.class);

=A0 =A0 conf.setInp= utFormat(TextInputFormat.class);

=A0 =A0 conf.setOutputFormat(TextOutputFormat.class);<= /div>

=A0 =A0

= =A0 =A0 =A0FileInputFor= mat.setInputPaths(conf, new Path(args[0]));

=A0 =A0 =A0FileOutputFormat.setOutputPath(= conf, new Path(args[1]));

=A0 =A0 =A0

=A0 =A0 =A0JobClient= .runJob(conf);

=A0 =A0 =A0

}

//-----------------------------------------------= ----------------------------------------------

Please help me to resolve this issue.

R= egards,

Senthil

=A0=A0

--047d7b2e121ff5673404f38c1f16--