Mapreduce運行任務出現Error: java.lang.RuntimeException: PipeMapRed.waitOutputThreads()

1、最近運行MapReduce任務一直出現下面這個問題，找人幫忙看，最後終於發現問題的點了，原來是自己代碼有點問題，一個方法名寫錯了，導致這個問題困擾了自己很久，下面我就將問題的錯誤貼出來，錯誤如下： packageJobJar: [./map.py, /tmp/hadoop-unjar6994337348538798719/] [] /tmp/streamjob53326448891375102

>>阅读原文<<