When I set job.setPartitionerClass(MyPartitioner.class); job.setNumReduceTasks(4);
I would expect to see my MyParitioner get called with getPartition(key, value, 4) but still I see it only get called with 1. If also tried setting conf.set("mapred.map.tasks.speculative.execution", "false"); conf.set("mapred.reduce.tasks.speculative.execution", "false"); What am I missing here? cheers -- Torsten