在pig脚本中声明错误

brjng4g3  于 2021-06-02  发布在  Hadoop
关注(0)|答案(0)|浏览(201)
%declare SOURCEPATH '/user/training/us_records/us-500.csv'  
%declare STOREPATH '/user/training/us_records/us_result.csv'  
table_data = LOAD '/user/training/us_records/us-500.csv' USING     PigStorage(',')  
AS(firstname :CHARARRAY,
lastname :CHARARRAY,
company :CHARARRAY,
address :CHARARRAY,
city :CHARARRAY,
country :CHARARRAY,
state :CHARARRAY,
zip :INT,
phone1: INT,
phone2 :INT,
email :CHARARRAY,
web :CHARARRAY);  
people_sample = GROUP table_data BY (country,state);  
pss = SAMPLE people_sample 0.01;  
STORE pss INTO '$STOREPATH';

结果:消息:org.apache.pig.backend.executionengine.exeception:错误2118:输入路径不存在:文件:/user/training/us\u records/us-500.csv

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题