请问下，conf.setNumReduceTasks(2);怎么输出的还是一个文件呢，不应个是2个吗

请问下，conf.setNumReduceTasks(2);怎么输出的还是一个文件呢，不应个是2个吗

我的两个reduce，不应该是最后有两个reduce输出的文件吗？但是和conf.setNumReduceTasks(1);的结果一样的

这是为什么？

你是一个datanode吧，一个datanode可以启动一个reducer，因为reduce默认是要在map全部结束后立即启动，所以其实你就只有一个reduce跑起来了。1个datanode上是可以跑多个task，task是一个reducer在处理的时候多线程处理。所以结果是这样的。