All right, Thanks

2012/9/26 George Datskos <[email protected]>

>  Hey Jason,
>
> This should return the number of active tasktrackers in the cluster:
> int numNodes = new JobClient(conf).getClusterStatus().getTaskTrackers()
>
>
>
>  Hi, all
>
>  As I have to run my MapReduce program on clusters of different size, and
> I would like the reducer number adapt to (0.95 * NodeNo. *
> mapred.tasktracker.reduce.tasks.maximum) automatically, so I was wondering
> how to get get the number of node in cluster in a MapReduce Job?
>
>  --
> YANG, Lin
>
>
>


-- 
YANG, Lin

Reply via email to