Unexpected data type -1 found in stream in PIG-0.8.1-src and Cassandra-0.8-src

[venkat]

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