Is this maybe related to CASSANDRA-2851 (make hexToBytes refuse invalid
input?).
hexToBytes() will throw exceptions if the input has an odd number of
characters, or contains on-hex characters (or is null).
On 16 February 2012 18:00, PJunk <pajgaon...@rhapsody.com> wrote:
>
> Hello,
>
> We are trying to read data from cassandra via pig. The version of
> cassandra is
> 1.0.7 and pig is 0.9.0.
>
> We get the following error when we try to load the data from the cassandra
> keyspace and columnfamily.
>
> [main] ERROR org.apache.pig.tools.grunt.Grunt - ERROR 2997: Unable to
> recreate
> exception from backed error: Error:
> org.apache.cassandra.utils.FBUtilities.hexToBytes(Ljava/lang/String;)[B
>
>
> Following is the pig script:
>
> register /var/pig-0.9.0/lib/pygmalion-1.0.0.jar;
>
> define FromCassandraBag org.pygmalion.udf.FromCassandraBag();
>
> rows = LOAD 'cassandra://Keyspace/ColumnFamily'
> USING org.apache.cassandra.hadoop.pig.CassandraStorage()
> AS (key, columns: bag {T: tuple(columnname, value)}) ;
>
> DUMP rows;
>
>
> The Cassandra Columnfamily looks like:
>
> Key Validation Class: org.apache.cassandra.db.marshal.UTF8Type
> Default column value validator:
> org.apache.cassandra.db.marshal.BytesType
> Columns sorted by: org.apache.cassandra.db.marshal.UTF8Type
> Row cache size / save period in seconds / keys to save : 0.0/0/all
> Row Cache Provider:
> org.apache.cassandra.cache.ConcurrentLinkedHashCacheProvider
> Key cache size / save period in seconds: 200000.0/14400
> GC grace seconds: 864000
> Compaction min/max thresholds: 4/32
> Read repair chance: 1.0
> Replicate on write: false
> Bloom Filter FP chance: default
> Built indexes: []
> Compaction Strategy:
> org.apache.cassandra.db.compaction.SizeTieredCompactionStrategy
>
> Has anyone come across this error and have a solution?
>
> Any help is appreciated.
>
> Thanks
>
>
>
>
>
