Grokbase Groups Pig user April 2011
FAQ
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

Search Discussions

  • Thejas M Nair at Apr 29, 2011 at 12:43 am
    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" 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



    --
  • Himanshu at Apr 29, 2011 at 6:17 pm
    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 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" 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



    --
  • Jeremy Hanna at Apr 29, 2011 at 6:54 pm
    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 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" 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



    --

Related Discussions

Discussion Navigation
viewthread | post
Discussion Overview
groupuser @
categoriespig, hadoop
postedApr 28, '11 at 8:58p
activeApr 29, '11 at 6:54p
posts4
users3
websitepig.apache.org

People

Translate

site design / logo © 2021 Grokbase