Hadoop猪拉丁语无法通过python脚本流

Question

我有一个简单的python脚本(moo.py),我试图流

import sys, os
for line in sys.stdin:
    print 1;

我试着运行这个猪脚本

DEFINE CMD `python moo.py` ship('moo.py');
data = LOAD 's3://path/to/my/data/*' AS (a:chararray, b:chararray, c:int, d:int);
res = STREAM data through CMD;
dump res;

当我运行这个猪脚本本地(猪-x本地)一切都很好,但当我没有-x本地运行它时,它打印出这个错误

[main] ERROR org.apache.pig.tools.grunt.Grunt - 错误2017:创建作业配置的内部错误.

[日志文件]

引起:java.io.FileNotFoundException:文件moo.py不存在.

任何的想法？

Answer 1

它很可能是相对路径的问题.

尝试:

DEFINE CMD `python moo.py` ship('/local/path/to/moo.py');

它也可能是读/写/执行权限的问题.