Mailing-List: contact common-user-help@hadoop.apache.org; run by ezmlm
Precedence: bulk
Reply-To: common-user@hadoop.apache.org
Received-SPF: pass (athena.apache.org: domain of
 prvs=929b6fd6e=akhaled@utdallas.edu designates 129.110.20.112 as permitted
 sender)
Message-Id: <569A0069-064D-4A7F-87D7-F757F4FE9A61@utdallas.edu>
From: Arindam Khaled <akhaled@utdallas.edu>
To: common-user@hadoop.apache.org
Content-Type: multipart/alternative; boundary=Apple-Mail-1-173629717
Mime-Version: 1.0 (Apple Message framework v936)
Subject: wrong value class error
Date: Mon, 15 Nov 2010 18:05:58 -0600

--Apple-Mail-1-173629717
Content-Type: text/plain;
	charset=US-ASCII;
	format=flowed;
	delsp=yes
Content-Transfer-Encoding: 7bit

Hello,

I am new to Hadoop and I think I'm doing something silly. I sent this  
e-mail from another account which isn't registered to hadoop user group.

I am getting the following error in my reducer.

10/11/15 15:29:11 WARN mapred.LocalJobRunner: job_local_0001
java.io.IOException: wrong value class: class  
org.apache.hadoop.io.Text is not class org.apache.hadoop.io.IntWritable

Here is my reduce class:

  public static class BFIDAReducer
        extends Reducer<Text,IntWritable,Text,Text> {
     private Text result = new Text();

     public void reduce(Text key, Iterable<IntWritable> values,
                        Context context
                        ) throws IOException, InterruptedException {
       Text result = new Text();
       GameFunctions gf = GameFunctions.getInstance();


       String line = "";

       for(IntWritable val: values)
         {
             line = line + val.toString() + ",";
         }

         if(line.length() > 1)
             line = (String) line.subSequence(0, line.length() - 1);

     if (gf.isSolved(key.toString(), size))
             solved = true;

       result.set(line);
       context.write(key, result);
     }
   }

And here is my partial code from job configuration:

     job.setOutputKeyClass(Text.class);
     job.setOutputValueClass(Text.class);
     job.setMapOutputKeyClass(Text.class);
     job.setMapOutputValueClass(IntWritable.class);

Can anyone help me?


I know I'll have more question in near future.

Thanks in advance.

Arindam


--Apple-Mail-1-173629717--