On Fri, 21 Mar 2008, Jean-Pierre OCALAN wrote:

> Hi,
>
> I'm currently working on a project that implies massive log parsing. I have
> one master and 6 slaves.
> By looking the each slaves logs I've noticed that REDUCE operation just runs
> on one machine.
> So does that mean that reduce just runs on one machine ? And if that is true
> how can I specify that I want the reduce to run also on the other machines ?
You can set it in your job using JobConf.setNumReduceTasks(numReducers).
How are you submitting your job? Is it from examples or your own code?
Amar
>
> Thanks for any help,
>
> Jean-Pierre.
>
>
>

Reply via email to