Hey Jason, This should return the number of active tasktrackers in the cluster: int numNodes = new JobClient(conf).getClusterStatus().getTaskTrackers()
Hi, allAs 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
