[CASSANDRA-5098] CassandraStorage doesn't decode name in widerow mode

• Type: Bug
• Status: Resolved
• Priority: Normal
• Resolution: Fixed
• Fix Version/s: 1.1.9, 1.2.1
• Labels: cassandra hadoop pig

Environment

Ubuntu 12.04.1 x64, Cassandra 1.1.8

• Severity: Normal
• Assignee: Brandon Williams
• Reporter: Justen Walker

Authors

Brandon Williams

Reviewers

Aleksey Yeschenko

• Created: 02/Jan/13 17:08
• Updated: 16/Apr/19 09:32
• Resolved: 04/Jan/13 17:13

Description

CassandraStorage doesn't decode name in widerow mode. This causes functions such as FILTER to fail with a ClassCastException, since the key is a bytearray instead of a chararray.

test.pig

DEFINE CassandraStorage org.apache.cassandra.hadoop.pig.CassandraStorage;

A  = LOAD 'cassandra://Metrics/EventEntries?widerows=true' USING CassandraStorage();
-- describe A --> A: {key: chararray,columns: {(name: (),value: chararray)}}

B = FILTER A BY key matches '^user.hit';
-- Throws CCE: org.apache.pig.data.DataByteArray cannot be cast to java.lang.String