当Mapper没有数据输入，mapper.run中的while循环会调用context.nextKeyValue就返回false，于是便返回到runNewMapper中，在这里程序会关闭输入通道和输出通道，这里关闭输出通道并没有关闭collector，必须要先flush一下。当Mapper没有数据输入，mapper.run中的while循
阅读背景：
大数据：Map终结和Spill文件合并
来源：互联网
分享到：
