Hi, I'm having multiple hadoop jobs that use the avro mapred API. Only in one of the jobs I have a visible mismatch between a number of map output records and reducer input records.
Does anybody encountered such a behavior? Can anybody think of possible explanations of this phenomenon? Any pointers/thoughts are highly appreciated! Best, Vyacheslav