job.setNumReduceTasks(4);
如果数据分布不均匀,就有可能在reduce阶段产生数据倾斜。
注意: reducetask数量并不是任意设置,还要考虑业务逻辑需求,有些情况下,需要计算全局汇总结果,就只能有1个reducetask。
Reducetask并行度机制
原文:https://www.cnblogs.com/TiePiHeTao/p/2a3f470617adbdf6c30b8f22365c3ec3.html