[CASSANDRA-3962] CassandraStorage can't cast fields from a CF correctly

• Type: Bug
• Status: Resolved
• Priority: Normal
• Resolution: Fixed
• Fix Version/s: 1.0.9, 1.1.0
• Labels: hadoop pig

Environment

OSX 10.6.latest, Pig 0.9.2.

• Severity: Normal
• Assignee: Brandon Williams
• Reporter: Janne Jalkanen

Authors

Brandon Williams

Reviewers

Pavel Yaskevich

• Created: 26/Feb/12 20:51
• Updated: 16/Apr/19 09:32
• Resolved: 27/Feb/12 17:04

Description

Included scripts demonstrate the problem. Regardless of whether the key is cast as a chararray or not, the Pig scripts fail with

java.lang.ClassCastException: org.apache.pig.data.DataByteArray cannot be cast to java.lang.String
	at org.apache.pig.backend.hadoop.HDataType.getWritableComparableTypes(HDataType.java:72)
	at org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigGenericMapReduce$Map.collect(PigGenericMapReduce.java:117)
	at org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigGenericMapBase.runPipeline(PigGenericMapBase.java:269)
	at org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigGenericMapBase.map(PigGenericMapBase.java:262)
	at org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigGenericMapBase.map(PigGenericMapBase.java:64)
	at org.apache.hadoop.mapreduce.Mapper.run(Mapper.java:144)
	at org.apache.hadoop.mapred.MapTask.runNewMapper(MapTask.java:764)
	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:370)
	at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)