MapReduce, mail # user - query number of mappers in 0.22 mapreduce API

query number of mappers in 0.22 mapreduce API

Radim Kolar 2012-03-04, 16:25

I switched to new mapreduce API. I need a replacement for

job.getNumMapTasks())

in job driver.

Re: query number of mappers in 0.22 mapreduce API

Harsh J 2012-03-04, 17:04

Radim,

This does not exist yet as a direct API but its a fair thing to demand
from a submitted job configuration (as that does hold the truthful
value). Please file a JIRA for adding this to JobContext. Do let this
thread know the JIRA ID once you've filed it (under MAPREDUCE).

For now, do:
job.getConfiguration().getInt(MRJobConfig.NUM_MAPS);

2012/3/4 Radim Kolar <[EMAIL PROTECTED]>:
> I switched to new mapreduce API. I need a replacement for
>
> job.getNumMapTasks())
>
> in job driver.

--
Harsh J

Re: query number of mappers in 0.22 mapreduce API

Radim Kolar 2012-03-04, 19:57

Please file a JIRA for adding this to JobContext. Do let this thread
know the JIRA ID once you've filed it (under MAPREDUCE).

MAPREDUCE-3968 <https://issues.apache.org/jira/browse/MAPREDUCE-3968>