PushDownForeachFlatten shall not push ForEach below Join if the flattened
fields is used in Join
------------------------------------------------------------------------------------------------
Key: PIG-1172
URL: https://issues.apache.org/jira/browse/PIG-1172
Project: Pig
Issue Type: Bug
Components: impl
Affects Versions: 0.6.0
Reporter: Daniel Dai
Assignee: Daniel Dai
Fix For: 0.6.0
Currently the following script will push B below D. But we will use fattened
column in the join, we cannot push that.
A = load '1.txt' as (bg:bag{t:tuple(a0,a1)});
B = FOREACH A generate flatten($0);
C = load '3.txt' AS (c0, c1);
D = JOIN B by a1, C by c1;
E = limit D 10;
explain E;
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
