[PIG-550] java.lang.ClassCastException: java.lang.String cannot be cast to org.apache.pig.data.Tuple

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Duplicate
• Affects Version/s: 0.2.0
• Fix Version/s: 0.2.0
• Assignee: Unassigned
• Reporter: Viraj Bhat
• Created: 01/Dec/08 20:32
• Updated: 24/Mar/10 22:04
• Resolved: 04/Dec/08 20:02

Description

======================================================================================================================
Map tasks resulting from the below Pig Script throws the following exception. Note 'one' is a dummy input containing, number 1.
======================================================================================================================

A = load 'one' using PigStorage() as ( one );
B = foreach A generate
        {
                (
                ('p1-t1-e1', 'p1-t1-e2'),
                ('p1-t2-e1', 'p1-t2-e2')
                ),
                (
                ('p2-t1-e1', 'p2-t1-e2'),
                ('p2-t2-e1', 'p2-t2-e2')
                )
        };
describe B;
C = foreach B generate
        $0 as pairbag { pair: ( t1: (e1, e2), t2: (e1, e2) ) }; describe C;
D = foreach C generate FLATTEN(pairbag);
describe D;
E = foreach D generate
        pair.t1.e2      as t1e2,
        pair.t2.e1      as t2e1;
describe E;
dump E;

======================================================================================================================
2008-12-01 20:07:53,974 [main] ERROR org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.Launcher - Error message from task (map) task_200810152105_0207_m_000000java.lang.ClassCastException: java.lang.String cannot be cast to org.apache.pig.data.Tuple
at org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POProject.getNext(POProject.java:279)
at org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator.processInput(PhysicalOperator.java:226)
at org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POProject.getNext(POProject.java:133)
at org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.POProject.getNext(POProject.java:233)
at org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POForEach.processPlan(POForEach.java:254)
at org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POForEach.getNext(POForEach.java:180)
at org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigMapBase.runPipeline(PigMapBase.java:170)
at org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigMapBase.map(PigMapBase.java:158)
at org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigMapOnly$Map.map(PigMapOnly.java:65)
at org.apache.hadoop.mapred.MapRunner.run(MapRunner.java:47)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:227)
at org.apache.hadoop.mapred.TaskTracker$Child.main(TaskTracker.java:2209)
======================================================================================================================