DSuiter RDX <[email protected]> writes: > protected void map(AvroKey<Event> key, Iterable<NullWritable> values, > Context context) throws IOException, InterruptedException {
It looks like your `map()` method doesn’t have the right type signature, seemingly following what’s necessary for `Reducer#reduce()` instead. Without an `@Override` annotation, I believe this is silently defining a separate `map()` method with a different type signature, leaving the default pass-through `Mapper#map()` as-in. -Marshall
