Dear All,

There seems to be something strange going on with projections in Pig 0.8, 
namely I get a projection on the wrong columns. I am using the following test 
case:

> cat testdata
a       b       c
a       d       e
----
in = LOAD 'testdata' USING PigStorage('\t') AS (S:chararray, P:chararray, 
O:chararray);
S1 = FILTER in BY P eq 'b';
S2 = FILTER in BY P eq 'd';
Join0 = JOIN S1 BY S, S2 BY S;
Join0P = FOREACH Join0 GENERATE S1::S,S1::O,S2::O;
DUMP Join0;
(a,b,c,a,d,e) ----- correct
DUMP Join0P;
(a,c,c) ------------- wrong, should be: (a,c,e)


Is there something wrong with the above script, or this is a bug?

Regards,
Spyros

Reply via email to