如何在 hadoop 流中运行 python3 代码？

如何解决如何在 hadoop 流中运行 python3 代码？

我安装了两个版本的python。每当我包含 #!/usr/bin/python (python2.7) 时。该代码有效。但是，当我切换到 #!/usr/bin/python3 (python3.6) 时。 mapreduce 作业显示错误。

Error: java.lang.RuntimeException: PipeMapRed.waitOutputThreads(): subprocess Failed with code 1
    at org.apache.hadoop.streaming.PipeMapRed.waitOutputThreads(PipeMapRed.java:326)
    at org.apache.hadoop.streaming.PipeMapRed.mapRedFinished(PipeMapRed.java:539)
    at org.apache.hadoop.streaming.PipeMapper.close(PipeMapper.java:130)
    at org.apache.hadoop.mapred.MapRunner.run(MapRunner.java:61)
    at org.apache.hadoop.streaming.PipeMapRunner.run(PipeMapRunner.java:34)
    at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:465)
    at org.apache.hadoop.mapred.MapTask.run(MapTask.java:349)
    at org.apache.hadoop.mapred.YarnChild$2.run(YarnChild.java:174)
    at java.security.AccessController.doPrivileged(Native Method)
    at javax.security.auth.Subject.doAs(Subject.java:422)
    at org.apache.hadoop.security.UserGroupinformation.doAs(UserGroupinformation.java:1730)
    at org.apache.hadoop.mapred.YarnChild.main(YarnChild.java:168)

此外，如果我在终端中输入 /usr/bin/python3。它打开了一个 python3.6 提示。