回答此问题可获得 20 贡献值,回答如果被采纳可获得 50 分。
<p>我有一个简单的Pig脚本,它使用了我创建的Python UDF。如果我删除了UDF部分,脚本将很好地完成。但是当我试图注册我的自定义项时,我得到了以下错误:</p>
<pre><code>ERROR 2997: Encountered IOException. File pig_test/py_udf_substr.py does not exist
</code></pre>
<p>这是我的自定义项:</p>
^{pr2}$
<p>这是我的猪剧本:</p>
<pre><code>REGISTER 'pig_test/py_udf_substr.py' USING jython as pyudf;
A = load 'pig_test/sf.txt' using PigStorage(',')
as (Unique_flight_ID,Year,Month,Day,DOW,
Scheduled_departure_time,Scheduled_arrival_time,
Airline,Flight_number,Tail_number,Plane_model,
Seat_configuration,Departure_delay,Origin_airport,
Destination_airport,Distance_travelled,Taxi_time_in,
Taxi_time_out,Cancelled,Cancellation_code,target);
B = FOREACH A GENERATE Unique_flight_ID, pyudf.get_fistsn($0,3);
DUMP B;
</code></pre>
<p>我用顺化来对付猪。数据和自定义项都在同一个HDFS位置(pig_test)。在</p>