I've seen this before when some data was a null, and I wasn't checking for it. Have you tried stepping through the pig script by
1. pig -r ...... (generates script with any variables replaced) 2. copy / paste lines into a grunt shell This will tell you (most of the time) where the problem lies in your script. -Matt On Thu, Jun 23, 2011 at 5:26 AM, venkat <venkatarama...@fifthgentech.com>wrote: > Hi, > > Previously we had cassandra-0.7.6-2 setup installed in a cluster and used > PIG Scripts for reading data from cassandra DB. > > Right now we changed our Cassandra version from Cassandra-0.7.6-2 to > Cassandra-0.8.0 and the cassandra cluster working fine now, but while > reading from cassandra using Pig-0.8.1 is throwing below error. > > "2011-06-23 03:06:58,629 [Thread-13] WARN > org.apache.hadoop.mapred.**LocalJobRunner > - job_local_0001 > java.lang.RuntimeException: Unexpected data type -1 found in stream. > at org.apache.pig.data.**BinInterSedes.writeDatum(** > BinInterSedes.java:478) > at org.apache.pig.data.**BinInterSedes.writeTuple(** > BinInterSedes.java:541) > at org.apache.pig.data.**BinInterSedes.writeBag(** > BinInterSedes.java:522) > at org.apache.pig.data.**BinInterSedes.writeDatum(** > BinInterSedes.java:361) > at org.apache.pig.data.**BinInterSedes.writeTuple(** > BinInterSedes.java:541) > at org.apache.pig.data.**BinInterSedes.writeDatum(** > BinInterSedes.java:357) > at org.apache.pig.impl.io.**InterRecordWriter.write(** > InterRecordWriter.java:73) > at org.apache.pig.impl.io.**InterStorage.putNext(** > InterStorage.java:87) > at org.apache.pig.backend.hadoop.**executionengine.**mapReduceLayer.** > PigOutputFormat$**PigRecordWriter.write(**PigOutputFormat.java:138) > at org.apache.pig.backend.hadoop.**executionengine.**mapReduceLayer.** > PigOutputFormat$**PigRecordWriter.write(**PigOutputFormat.java:97) > at org.apache.hadoop.mapred.**MapTask$**NewDirectOutputCollector.** > write(MapTask.java:498) > at org.apache.hadoop.mapreduce.**TaskInputOutputContext.write(** > TaskInputOutputContext.java:**80) > at org.apache.pig.backend.hadoop.**executionengine.** > mapReduceLayer.PigMapOnly$Map.**collect(PigMapOnly.java:48) > at org.apache.pig.backend.hadoop.**executionengine.** > mapReduceLayer.PigMapBase.map(**PigMapBase.java:242) > at org.apache.pig.backend.hadoop.**executionengine.** > mapReduceLayer.PigMapBase.map(**PigMapBase.java:58) > 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)" > > please advice. > > thanks, > venkat >
