我使用python与hadoop流。尽管仔细的单元测试,错误难免蠕变当他们这样做,此错误消息是所有的Hadoop得出:有没有办法从hadoop流中的python脚本中获取信息错误?
java.lang.RuntimeException: PipeMapRed.waitOutputThreads(): subprocess failed with code 1
at org.apache.hadoop.streaming.PipeMapRed.waitOutputThreads(PipeMapRed.java:362)
at org.apache.hadoop.streaming.PipeMapRed.mapRedFinished(PipeMapRed.java:576)
...
的消息对于调试非常无益的。
有没有什么办法可以获得信息性的错误从hadoop流python脚本?
您是否找到解决方案? – pratiklodha