问题描述
- mapreduce的reduce个数设置无效,始终只有一个reduce任务,输出的文件也只有一个
-
job.setNumReduceTasks(2);
这样设置reduce个数无效,调试发现始终只有一个reduce任务,输出文件也就只有一个part-r-00000,如果加一句System.out.println(job.getNumReduceTasks());会发现打印出来的“NumReduceTasks”的确是2,但实际运行结果始终只有一个。
如果不在eclipse中运行,生成jar包运行也是一样。
网上有人说是伪分布模式或者单机模式就会这样,但我不是这种模式,我用虚拟机建了集群的。
请问这是怎么回事?
解决方案
自己解决了。。。。。。。。。
解决方案二:
请教下怎么解决的,我之前还可以分区,现在程序也不行了,只生成一个文档,求解!!
时间: 2024-11-08 21:55:15