[ https://issues.apache.org/jira/browse/CASSANDRA-5813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13722666#comment-13722666 ]
James Schappet commented on CASSANDRA-5813: ------------------------------------------- I found the issue: I was using the wrong partitioner in my .profile: "export PIG_PARTITIONER=org.apache.cassandra.dht.RandomPartitioner" Instead of: export PIG_INITIAL_ADDRESS=localhost export PIG_RPC_PORT=9160 export PIG_PARTITIONER=org.apache.cassandra.dht.Murmur3Partitioner Thanks for helping me verify this. > 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