Сбой сценария Pig из-за неправильной проекции поля в фильтре - PullRequest
0 голосов
/ 12 сентября 2018

Ниже приведен фрагмент кода, который я пытаюсь запустить, и столкнулся с проблемой недопустимого поля.

LIT__CALL_lt_CALL_segment_data = LOAD '/work/call/idrpnpc/lit/call/lt_call_segment' USING PigStorage('\u0001') AS (load_ts:chararray, source_location_id:chararray, destination_location_id:chararray, transportation_mode_cd:chararray, nifty_division_nbr:chararray, effective_dt:chararray, discontinue_dt:chararray, nifty_item_id:chararray, override_ind:chararray, planning_default_ind:chararray, order_duns_nbr:chararray, review_qty:int, contract_sopt_qty:int, calculated_sopt_qty:int, planning_sopt_qty:int, override_sopt_qty:int, transit_qty:int, put_away_qty:int, lead_time_variability_amt:chararray, customer_promise_factor_qty:int, customer_promise_day_qty:int, pick_up_day_nm:chararray,
arrival_day_nm:chararray, managed_vendor_ind:chararray, total_lead_time_qty:int, order_pattern_nm:chararray, order_interval_nm:chararray, order_policy_nm:chararray, source_location_level_cd:chararray, destination_location_level_cd:chararray, eligibility_status_cd:chararray, order_interval_qty:int, vendor_lead_time_qty:int, reporting_source_location_id:chararray, reporting_source_location_lead_time_qty:chararray, batchid:chararray);

LIT__CALL_lt_CALL_segment = foreach LIT__CALL_lt_CALL_segment_data generate
                                                                        source_location_id,
                                                                        destination_location_id,
                                                                        effective_dt,
                                                                        discontinue_dt,
                                                                        nifty_item_id,
                                                                        override_ind,
                                                                        planning_default_ind,
                                                                        total_lead_time_qty,
                                                                        order_interval_qty,
                                                                        destination_location_level_cd;


/*****************************filter LIT__CALL_lt_segment table***************************************************************/

LIT__CALL_lt_CALL_segment_warehouse_filter = FILTER LIT__CALL_lt_CALL_segment BY destination_location_level_cd == 'WAREHOUSE';

Получение ошибки ниже ошибочной проекции поля.

Неправильная проекция поля.Спроецированное поле [lit__call_lt_call_segment :: destination_location_level_cd] не существует в схеме: source_location_id: chararray, destination_location_id: chararray, эффективное_д.destination_location_level_cd: chararray.

Может кто-нибудь помочь мне в этом вопросе ??

Большое спасибо

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...