[
https://issues.apache.org/jira/browse/PIG-3458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13768718#comment-13768718
]
Koji Noguchi commented on PIG-3458:
-----------------------------------
bq. #2 has a simpler implementation as well. Just add one more check in
ScalarVisitor.
Yes, uploading a patch shortly. Thanks Mark, Daniel.
> ScalarExpression lost with multiquery optimization
> --------------------------------------------------
>
> Key: PIG-3458
> URL: https://issues.apache.org/jira/browse/PIG-3458
> Project: Pig
> Issue Type: Bug
> Reporter: Koji Noguchi
> Assignee: Koji Noguchi
>
> Our user reported an issue where their scalar results goes missing when
> having two store statements.
> {noformat}
> A = load 'test1.txt' using PigStorage('\t') as (a:chararray, count:long);
> B = group A all;
> C = foreach B generate SUM(A.count) as total ;
> store C into 'deleteme6_C' using PigStorage(',');
> Z = load 'test2.txt' using PigStorage('\t') as (a:chararray, id:chararray );
> Y = group Z by id;
> X = foreach Y generate group, C.total;
> store X into 'deleteme6_X' using PigStorage(',');
> ====Inputs
> pig> cat test1.txt
> a 1
> b 2
> c 8
> d 9
> pig> cat test2.txt
> a z
> b y
> c x
> pig>
> {noformat}
> Result X should contain the total count of '20' but instead it's empty.
> {noformat}
> pig> cat deleteme6_C/part-r-00000
> 20
> pig> cat deleteme6_X/part-r-00000
> x,
> y,
> z,
> pig>
> {noformat}
> This works if we take out first "store C" statement.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
