与这个问题类似,我的减速机没有运行。
不幸的是,他设置MapOutput{key|Value}的解决方案并不能解决我的问题。
对我有效的是改变我的reduce()
接收Iterable<MyWritable>
而不是Iterator<MyWritable>
,正如这篇文章所描述的。