2016-12-01 20 views
0

我寫了一個腳本豬:錯誤1003:無法找到別名truck_events_subset操作

truck_events = LOAD '/user/data/truck_event_text_partition.csv' USING PigStorage(',') 
AS (driverId:int, truckId:int, eventTime:chararray,     
eventType:chararray, longitude:double, latitude:double, 
eventKey:chararray, correlationId:long, driverName:chararray, 
routeId:long,routeName:chararray,eventDate:chararray); 
DESCRIBE truck_events; 
truck_events_subset = LIMIT truck_events 100; 
DESCRIBE truck_events_subset; 
DUMP truck_events_subset; 

但我得到一個錯誤:

ERROR org.apache.pig.tools.grunt .Grunt - 錯誤1003:無法找到一個 運營商別名中的correlationID領域truck_events_subset

+0

檢查是否通過dump_events轉儲數據是否正確加載。可能加載失敗。編輯問題並從文件中顯示示例數據。 –

+0

如何通過傾銷truck_events知道數據是否正確加載或失敗? –

+0

如果dump truck_events沒有顯示文件中的記錄,那麼這意味着您的加載失敗,在這種情況下,加載語句後的任何PIG語句都會引發錯誤。 –

回答

0

的數據是雙精度浮點POI nt number.Change數據類型加倍。

truck_events = LOAD '/user/data/truck_event_text_partition.csv' USING PigStorage(',') AS (driverId:int, truckId:int, eventTime:chararray,eventType:chararray, longitude:double, latitude:double,eventKey:chararray, correlationId:double, driverName:chararray,routeId:long,routeName:chararray,eventDate:chararray); 
相關問題