cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Brandon Williams (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (CASSANDRA-5813) PIG Error Using CqlStorage
Date Fri, 26 Jul 2013 20:39:48 GMT

    [ https://issues.apache.org/jira/browse/CASSANDRA-5813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13721186#comment-13721186
] 

Brandon Williams commented on CASSANDRA-5813:
---------------------------------------------

I'm unable to reproduce following your steps.

{noformat}
((user_id,jsmith),(age,42),(first,John),(last,Smith))
grunt> 
{noformat}
                
> PIG Error Using CqlStorage
> --------------------------
>
>                 Key: CASSANDRA-5813
>                 URL: https://issues.apache.org/jira/browse/CASSANDRA-5813
>             Project: Cassandra
>          Issue Type: Bug
>          Components: Hadoop
>    Affects Versions: 1.2.7
>            Reporter: James Schappet
>            Priority: Minor
>
> While trying to do a basic test with PIG in 1.2.7 I get the following exception:
> 2013-07-26 14:52:03,747 [Thread-6] WARN  org.apache.hadoop.mapred.LocalJobRunner - job_local_0001
> java.lang.RuntimeException
>         at org.apache.cassandra.hadoop.cql3.CqlPagingRecordReader$RowIterator.executeQuery(CqlPagingRecordReader.java:646)
>         at org.apache.cassandra.hadoop.cql3.CqlPagingRecordReader$RowIterator.<init>(CqlPagingRecordReader.java:283)
>         at org.apache.cassandra.hadoop.cql3.CqlPagingRecordReader.initialize(CqlPagingRecordReader.java:149)
>         at org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigRecordReader.initialize(PigRecordReader.java:181)
>         at org.apache.hadoop.mapred.MapTask$NewTrackingRecordReader.initialize(MapTask.java:522)
>         at org.apache.hadoop.mapred.MapTask.runNewMapper(MapTask.java:763)
>         at org.apache.hadoop.mapred.MapTask.run(MapTask.java:370)
>         at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:212)
> Caused by: InvalidRequestException(why:Expected 8 or 0 byte long (1))
>         at org.apache.cassandra.thrift.Cassandra$execute_prepared_cql3_query_result.read(Cassandra.java:41868)
>         at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:78)
>         at org.apache.cassandra.thrift.Cassandra$Client.recv_execute_prepared_cql3_query(Cassandra.java:1689)
>         at org.apache.cassandra.thrift.Cassandra$Client.execute_prepared_cql3_query(Cassandra.java:1674)
>         at org.apache.cassandra.hadoop.cql3.CqlPagingRecordReader$RowIterator.executeQuery(CqlPagingRecordReader.java:616)
>         ... 7 more
> SETUP:
> Create single Cassandra Instance
> Setup new schema:
>  CREATE SCHEMA schema1           WITH replication = { 'class' : 'SimpleStrategy', 'replication_factor'
: 1 };
> Create New Table:
> CREATE TABLE users (
>     user_id varchar PRIMARY KEY,
>     first varchar,
>     last varchar,
>     age int
> );
> Insert new User to table:
> INSERT INTO users (user_id, first, last, age)                   VALUES ('jsmith', 'John',
'Smith', 42);
> Launch Pig:
> cd examples/pig
> bin/pig_cassandra -x local 
> grunt>  rows = LOAD 'cql://schema1/users' USING CqlStorage();
> grunt> dump rows;
> Then you get the above error.

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira

Mime
View raw message