Projected field mapping does not exist in schema: string: bytearray

1) I have uploaded a folder to Apache.Pig without defining a delimiter specified as LINE. 2) I used PYTHON udf to filter the given line. But I am getting the above error.

REGISTER '/home/hadoop/alanGates/filter.py' using jython as filterfunction;
d = load '/home/hadoop/Desktop/' using PigStorage as line;
M = foreach d generate filterfunction.tuple_contains(line,Mariko);

      

Anyone could find this error and give me a solution.

+3


source to share





All Articles