[jira] [Created] (PIG-5381) Extra foreach in nested-foreach preventing Accumulator usage

[Koji Noguchi (JIRA)]

Koji Noguchi created PIG-5381:
---------------------------------

             Summary: Extra foreach in nested-foreach preventing Accumulator 
usage
                 Key: PIG-5381
                 URL: https://issues.apache.org/jira/browse/PIG-5381
             Project: Pig
          Issue Type: Bug
            Reporter: Koji Noguchi
            Assignee: Koji Noguchi


{code}
A = LOAD 'test.input1' AS (a1:int, a2:chararray, a3:int);
B = GROUP A by a1;
C = FOREACH B {
    C2 = FOREACH A generate a2, a3;
    GENERATE group, org.apache.pig.test.utils.AccumulatorBagCount(C2);
}

dump C;
{code} 

This simple code fails with 
{noformat}
Caused by: java.io.IOException: exec() should not be called.
        at 
org.apache.pig.test.utils.AccumulatorBagCount.exec(AccumulatorBagCount.java:56)
        at 
org.apache.pig.test.utils.AccumulatorBagCount.exec(AccumulatorBagCount.java:28)
        at 
org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POUserFunc.getNext(POUserFunc.java:332)
        ... 17 more
{noformat}

Somehow pig decides not to enable Accumulator in this case.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)