MRUnit reducer test: Mismatch in value class MRUnit reducer test: Mismatch in value class hadoop hadoop

MRUnit reducer test: Mismatch in value class


Please check the reduce method signature in your reducer implementation

It should be

public void reduce(Text key, Iterable<MyWritable> values, Context context) throws IOException, InterruptedException {

instead of

public void reduce(Text key, Iterator<MyWritable> values, Context context) throws IOException, InterruptedException {