Mapreduce运行任务出现Error: java.lang.RuntimeException: PipeMapRed.waitOutputThreads()

1、最近运行MapReduce任务一直出现下面这个问题,找人帮忙看,最后终于发现问题的点了,原来是自己代码有点问题,一个方法名写错了,导致这个问题困扰了自己很久,下面我就将问题的错误贴出来,错误如下: packageJobJar: [./map.py, /tmp/hadoop-unjar6994337348538798719/] [] /tmp/streamjob53326448891375102
相关文章
相关标签/搜索