您的位置：首页 > 编程语言 > Python开发

执行python的map reduce出错 io.IOException: Broken pipe lang.RuntimeException: PipeMapRed.waitO

2013-12-04 17:56 1251 查看

来源：http://stackoverflow.com/questions/5890188/hadoop-streaming-job-failed-in-python

java. io.IOException: Broken pipe 解决

-mapper  "python ./mapper.py"
-reducer "python ./reducer.py"

Try to enclose your input path in double quotes. (-input "/data/omni/20110115/exp6-10122")

lang.RuntimeException: PipeMapRed.waitOutputThreads()解决

hadoop jar hadoop-streaming*.jar  
-D stream.non.zero.exit.is.failure=false

内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理

标签：

相关文章推荐

新的分享

章节导航