[HBASE-1871] Wrong type used in TableMapReduceUtil.initTableReduceJob()

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.20.0
• Fix Version/s: 0.20.1, 0.90.0
• Hadoop Flags: Reviewed
• Assignee: Lars George
• Reporter: Lars George
• Created: 26/Sep/09 20:23
• Updated: 20/Nov/15 13:01
• Resolved: 26/Sep/09 21:23

Description

Since we changed it so that TableOutputFormat can handle Put and Delete it is necessary to set the output value class to Writable.

  public static void initTableReducerJob(String table,
    Class<? extends TableReducer> reducer, Job job, Class partitioner)
  throws IOException {
    job.setOutputFormatClass(TableOutputFormat.class);
    if (reducer != null) job.setReducerClass(reducer);
    job.getConfiguration().set(TableOutputFormat.OUTPUT_TABLE, table);
    job.setOutputKeyClass(ImmutableBytesWritable.class);
    job.setOutputValueClass(Put.class);
   ....

The last line should be

    job.setOutputValueClass(Writable.class);