Thanks Amareshwari - I reverted to the old API and carried on. Given that MR does not work in the current download using the non-deprecated API, might it be wise to release 0.20.2 now? The Hadoop download page currently provides 0.20.1 (http://ftp.download-by.net/apache/hadoop/core/)
Cheers, Tim On Wed, Oct 21, 2009 at 10:10 PM, Amareshwari Sri Ramadasu <[email protected]> wrote: > That was bug in 0.20. Got fixed in 0.20.2 through MAPREDUCE-112 > > Thanks > Amareshwari > > tim robertson wrote: >> >> Hi all, >> >> I have a Reducer with the following (using new API): >> >> public static class Transpose extends Reducer<Text, IntWritable, >> IntWritable, Text> { >> �...@override >> protected void reduce(Text key, Iterable<IntWritable> values, >> Context context) >> throws IOException, InterruptedException { >> int count = 0; >> for (IntWritable i : values) { >> context.write(i, key); >> count++; >> } >> context.setStatus(key.toString() + " has values: " + count); >> } >> } >> >> when running, this reports correctly: >> üksikute püriidistunud käikudega sinisavi has values: 2 > reduce >> >> but the always reports output records = 0. >> >> The job is launched: >> >> Job job = new Job(conf, "ClassificationMapReduce"); >> job.setJarByClass(ClassificationMapReduce.class); >> job.setMapperClass(ExtractClassification.class); >> job.setReducerClass(Transpose.class); >> job.setNumReduceTasks(9); >> >> job.setMapOutputKeyClass(Text.class); >> job.setMapOutputValueClass(IntWritable.class); >> job.setOutputKeyClass(IntWritable.class); >> job.setOutputValueClass(Text.class); >> >> FileInputFormat.addInputPath(job, new Path(otherArgs[0])); >> TextOutputFormat.setOutputPath(job, new Path(otherArgs[1])); >> >> Can someone please tell me where I am doing something wrong? >> >> Thanks >> Tim >> > >
