我在使用rmr2执行mapreduce时遇到了hdfs中csv数据集的问题。
对于1个文件，mapreduce工作正常，未发现任何错误，但当同一文件夹中有2个或更多数据集时，数据开始中断，结果开始中断，如下所示：

从第16行开始，错误开始，直到文件结束。
使用的mapreduce是：

calc = mapreduce(
 input="hdfs://127.0.0.1:8020/user/cloudera/flumeFinal",
  input.format=make.input.format(format="csv", sep = ",",
  col.names=col.names,stringsAsFactors=F),
    map=function(k,lines){
     k <- lines[2]
     return(keyval(k,1))
     },
    reduce= function(k,lines) {
     keyval(k,sum(lines))

有没有人曾经遇到过类似的问题，可以帮助解决这个问题？
谢谢，布鲁诺