【发布时间】:2014-02-08 09:52:41
【问题描述】:
我正在运行一个简单的流式 map-reduce 作业,但似乎无法解决此错误。
hadoop jar $HADOOP_HOME/contrib/streaming/hadoop-streaming-1.2.1.jar -input textDataFiles/* -output counts -file /home/hduser/first/mapper.py -mapper mapper.py -file /home/hduser/first/reducer.py -reducer reducer.py
结果是:
Warning: $HADOOP_HOME is deprecated.
packageJobJar: [/home/hduser/first/mapper.py, /home/hduser/first/reducer.py] [] /tmp/streamjob1639740860313757975.jar tmpDir=null
14/01/19 00:04:57 INFO util.NativeCodeLoader: Loaded the native-hadoop library
14/01/19 00:04:57 ERROR security.UserGroupInformation: PriviledgedActionException as:hduser cause:ENOENT: No such file or directory
14/01/19 00:04:57 ERROR streaming.StreamJob: Error Launching job : No such file or directory
Streaming Command Failed!
我的 mapper 和 reducer 没有什么特别之处——它是一个简单的字数统计脚本。有什么建议吗?
【问题讨论】:
-
您的命令行显示正确,因为使用了 -file 到完整路径,然后没有调用路径。我也会对答案感兴趣。
标签: python mapreduce hadoop-streaming