You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@pig.apache.org by Himanshu <he...@gmail.com> on 2011/04/28 21:05:13 UTC

cannot cast issue: Pig filter against flatten column

Hi Badri,

http://mail-archives.apache.org/mod_mbox/pig-user/201104.mbox/%3C009a01cbf5ba$232d61d0$69882570$@com%3E

Did you get a resolution on the above email post yet?


Thanks
Himanshu Garg
+1 203 308 6212

Re: cannot cast issue: Pig filter against flatten column

Posted by Jeremy Hanna <je...@gmail.com>.
A few questions:
What are you trying to do?  What is the pig script that you're trying to run?
What version of Cassandra?
What version of Pig?
Did you add any column_metadata to your column family, like a validation_class?

On Apr 28, 2011, at 7:58 PM, Himanshu wrote:

> java.lang.ClassCastException: org.apache.pig.data.DataByteArray cannot be
> cast to java.lang.String
> at
> org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.PORegexp.getNext(PORegexp.java:84)
> at
> org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POFilter.getNext(POFilter.java:148)
> at
> org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigMapBase.runPipeline(PigMapBase.java:236)
> at
> org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigMapBase.map(PigMapBase.java:231)
> at
> org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigMapBase.map(PigMapBase.java:53)
> at org.apache.hadoop.mapreduce.Mapper.run(Mapper.java:144)
> at org.apache.hadoop.mapred.MapTask.runNewMapper(MapTask.java:621)
> at org.apache.hadoop.mapred.MapTask.run(MapTask.java:305)
> at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:177)
> 2011-04-28 16:27:14,198 [main] INFO
> org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MapReduceLauncher
> - HadoopJobId: job_local_0001
> 
> Above is the complete stack trace, And I am also using CassandraStorage.
> What does declaring the schema with the column type as bytearray, and then
> do a cast Means?
> 
> 
> 
> 
> On Thu, Apr 28, 2011 at 8:43 PM, Thejas M Nair <te...@yahoo-inc.com> wrote:
> 
>> Are you also using CassandraStorage?
>> Can you paste the entire stack trace  ?
>> It seems CassandraStorage is returning a DataByteArray instead of String,
>> can you try declaring the schema with the column type as bytearray, and then
>> do a cast ?
>> 
>> Thanks,
>> Thejas
>> 
>> 
>> 
>> On 4/28/11 12:05 PM, "Himanshu" <he...@gmail.com> wrote:
>> 
>> Hi Badri,
>> 
>> 
>> http://mail-archives.apache.org/mod_mbox/pig-user/201104.mbox/%3C009a01cbf5ba$232d61d0$69882570$@com%3E
>> 
>> Did you get a resolution on the above email post yet?
>> 
>> 
>> Thanks
>> Himanshu Garg
>> +1 203 308 6212
>> 
>> 
>> 
>> --
>> 
>>

Re: cannot cast issue: Pig filter against flatten column

Posted by Himanshu <he...@gmail.com>.
java.lang.ClassCastException: org.apache.pig.data.DataByteArray cannot be
cast to java.lang.String
at
org.apache.pig.backend.hadoop.executionengine.physicalLayer.expressionOperators.PORegexp.getNext(PORegexp.java:84)
at
org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POFilter.getNext(POFilter.java:148)
at
org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigMapBase.runPipeline(PigMapBase.java:236)
at
org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigMapBase.map(PigMapBase.java:231)
at
org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigMapBase.map(PigMapBase.java:53)
at org.apache.hadoop.mapreduce.Mapper.run(Mapper.java:144)
at org.apache.hadoop.mapred.MapTask.runNewMapper(MapTask.java:621)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:305)
at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:177)
2011-04-28 16:27:14,198 [main] INFO
 org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MapReduceLauncher
- HadoopJobId: job_local_0001

Above is the complete stack trace, And I am also using CassandraStorage.
What does declaring the schema with the column type as bytearray, and then
do a cast Means?




On Thu, Apr 28, 2011 at 8:43 PM, Thejas M Nair <te...@yahoo-inc.com> wrote:

>  Are you also using CassandraStorage?
> Can you paste the entire stack trace  ?
> It seems CassandraStorage is returning a DataByteArray instead of String,
> can you try declaring the schema with the column type as bytearray, and then
> do a cast ?
>
> Thanks,
> Thejas
>
>
>
> On 4/28/11 12:05 PM, "Himanshu" <he...@gmail.com> wrote:
>
> Hi Badri,
>
>
> http://mail-archives.apache.org/mod_mbox/pig-user/201104.mbox/%3C009a01cbf5ba$232d61d0$69882570$@com%3E
>
> Did you get a resolution on the above email post yet?
>
>
> Thanks
> Himanshu Garg
> +1 203 308 6212
>
>
>
> --
>
>

Re: cannot cast issue: Pig filter against flatten column

Posted by Thejas M Nair <te...@yahoo-inc.com>.
Are you also using CassandraStorage?
Can you paste the entire stack trace  ?
It seems CassandraStorage is returning a DataByteArray instead of String, can you try declaring the schema with the column type as bytearray, and then do a cast ?

Thanks,
Thejas


On 4/28/11 12:05 PM, "Himanshu" <he...@gmail.com> wrote:

Hi Badri,

http://mail-archives.apache.org/mod_mbox/pig-user/201104.mbox/%3C009a01cbf5ba$232d61d0$69882570$@com%3E

Did you get a resolution on the above email post yet?


Thanks
Himanshu Garg
+1 203 308 6212



--