job.setNumReduceTasks(2);
这样设置reduce个数无效,调试发现始终只有一个reduce任务,输出文件也就只有一个part-r-00000,如果加一句System.out.println(job.getNumReduceTasks());会发现打印出来的“NumReduceTasks”的确是2,但实际运行结果始终只有一个。
如果不在eclipse中运行,生成jar包运行也是一样。
网上有人说是伪分布模式或者单机模式就会这样,但我不是这种模式,我用虚拟机建了集群的。
请问这是怎么回事?
mapreduce的reduce个数设置无效,始终只有一个reduce任务,输出的文件也只有一个
- 写回答
- 好问题 0 提建议
- 关注问题
- 邀请回答
-