localJobRunner:
cdh:
int numReduceTasks = this.job.getNumReduceTasks();
if (numReduceTasks > 1 || numReduceTasks < 0) {
numReduceTasks = 1;
this.job.setNumReduceTasks(1);
}
Apache :
int numReduceTasks = job.getNumReduceTasks();
用户设置为几 程序就启动几个 可以直接显示出执行效果localJobRunner:
cdh:
int numReduceTasks = this.job.getNumReduceTasks();
if (numReduceTasks > 1 || numReduceTasks < 0) {
numReduceTasks = 1;
this.job.setNumReduceTasks(1);
}
Apache :
int numReduceTasks = job.getNumReduceTasks();
用户设置为几 程序就启动几个 可以直接显示出执行效果
cdh 2.6.0版本和apache 2.7.x版本 本地执行环境的差异。
原文：https://www.cnblogs.com/TiePiHeTao/p/2bafe37e92fbcabae3ce8122c33f65d9.html