1.执行MR任务报Error: java.lang.RuntimeException: PipeMapRed.waitOutputThreads():?subprocess failed with code 1

可能是map 的结果中存在参数不一致的情况导致的 还有就是map.py 或是 red.py要有执行权限 chmod +x map.py red.py

方案二：在run.sh 里面设置：-D "stream.non.zero.exit.is.failure=false ;?map-reduce程序返回值不做判断；streaming默认的情况下，mapper和reducer的返回值不是0，被认为异常任务，将被再次执行，默认尝试4次都不是0，整个job都将失败。而grep在没有匹配结果时返回1

出现这种pipe 问题三种情况 1.代码问题? 2.文件执行权限问题? 3.环境问题

ss = line.strip().split('\t')

? ? ? ? if len(ss) != 2:

? ? ? ? ? ? ? ? continue

? ? ? ? word, cnt = ss