Dear All,
I am consistently getting following error on execution of my pig script:
" [main] ERROR org.apache.pig.tools.grunt.Grunt - ERROR 2997: Unable
to recreate exception from backed error: java.lang.ClassCastException:
org.apache.pig.data.DataByteArray cannot be cast to java.lang.String"
I have checked my input files and they seem to have inputs in the
right format. My pig script is as follows:
At this point I am unable to figure out whats going wrong at my end.
Any helpful info on the problem will be appreciated.
Thanks and regards,
Ips
register piggybank.jar;
register joda-time-1.6.jar ;
A= LOAD 'date.csv' USING PigStorage(',') AS (a1:chararray);
o1 = load 'obsv.csv'
as (obs_id:chararray, en_id:chararray, sub_en_id:chararray,
o_by:chararray, v_by:chararray, rmk:chararray);
oc1 = load 'obsv_concpt.csv' as (obs_id:chararray,
concept_id:chararray, concept_val:chararray);
l1 = load 'locations.csv'
as (lid:chararray, lng:chararray, lt:chararray, field1:chararray,
field2:chararray, field3:chararray, field4:chararray,
field5:chararray, field6:chararray, field7:chararray,
field8:chararray, field9:chararray);
e1 = load 'encntr.csv'
as (en_id:chararray, pid:chararray, lid:chararray, edttime:chararray);
p1 = load 'persons.csv'
as (pid:chararray, gen:chararray, giv_nm:chararray, middle:chararray,
fm_nm:chararray, bdt:chararray,
bdt_est:chararray, bt_pl:chararray, mnm:chararray,
sps_nm:chararray,
dth_dt:chararray, dth_dt_estm:chararray, lid:chararray,
mrr_dt:chararray,
mrr_dt_estm:chararray, entry_date:chararray,
mrr_dt_sts:chararray,
contact_number:chararray,
fth_name:chararray);
pid = load 'p_pat_id_type.csv'
as (p_pat_id_type_id:chararray, pid:chararray, p_pat_id:chararray);
f1 = load 'families.csv'
as (fam_id:chararray, fam_hd:chararray, identifier:chararray);
oc1 = filter oc1 by concept_id eq '55';
temp = join oc1 by obs_id, o1 by obs_id;
temp = join temp by o1::en_id, e1 by en_id;
temp = join p1 by pid, temp by e1::pid;
temp = join l1 by lid, temp by p1::lid;
temp = join f1 by fam_hd, temp by p1::pid;
temp = join pid by pid, temp by p1::pid;
temp = group temp by p1::pid;
temp = foreach temp generate
flatten(temp),org.apache.pig.builtin.MAX(temp.oc1::concept_val) as
elmp;
temp = foreach temp generate
pid::p_pat_id_type_id as p_pat_id_type_id,
p1::giv_nm as giv_nm,
p1::mnm as mnm,
pid::p_pat_id as p_pat_id,
l1::field3 as field3,
p1::bdt as bdt,
elmp as elmp;
temp = foreach temp generate
p_pat_id_type_id as p_pat_id_type_id,
giv_nm as giv_nm,
mnm as mnm,
p_pat_id as p_pat_id,
field3 as field3,
bdt as bdt,
elmp as elmp,
org.apache.pig.piggybank.evaluation.string.SUBSTRING(bdt,0,10)
as bdt;
temp = foreach temp generate
p_pat_id_type_id as p_pat_id_type_id,
giv_nm as giv_nm,
mnm as mnm,
p_pat_id as p_pat_id,
field3 as field3,
bdt as bdt,
org.apache.pig.piggybank.evaluation.string.REPLACE(elmp,'-','') as elmp,
org.apache.pig.piggybank.evaluation.string.REPLACE(bdt,'-','')
as bdt;
temp = foreach temp generate
giv_nm as giv_nm,
mnm as mnm,
p_pat_id as p_pat_id,
field3 as field3,
org.apache.pig.piggybank.evaluation.datetime.DiffDate(
A.$0, bdt) / 365 as Age,
elmp as elmp;
temp = filter temp by org.apache.pig.piggybank.evaluation.datetime.DiffDate(
A.$0,LMP)/30 <= 9;
On executing this last step I get the exception........................
