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
