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

Reply via email to