NumReduceTasks的个数问题
来源:4-17 流量统计实战升级之自定义Partitioner
慕沐3571032
2020-09-02
当job.setNumReduceTasks()的个数大于自定义Partitioner中的分区规则个数时,程序正常执行,相当于多分配了几个reducetask任务,多分配的reducetask没有干活而已
当job.setNumReduceTasks()的个数小于自定义Partitionew中的分区规则个数时,job.waitForCompletion()会输出返回false,同时没有输出文件
pk哥 这样说对吗??
写回答
1回答
-
Michael_PK
2020-09-03
三个场景你可以动手测试下:
1)reduce > partition
2) 1 < reduce < partition
3) reduce = 1
122021-07-27
相似问题