[jira] [Commented] (CASSANDRA-5813) PIG Error Using CqlStorage
[
https://issues.apache.org/jira/browse/CASSANDRA-5813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=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
[jira] [Commented] (CASSANDRA-5813) PIG Error Using CqlStorage
[
https://issues.apache.org/jira/browse/CASSANDRA-5813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13721147#comment-13721147
]
James Schappet commented on CASSANDRA-5813:
---
tsunami:~ schappetj$ uname -an
Darwin tsunami.icts.uiowa.edu 11.4.2 Darwin Kernel Version 11.4.2: Thu Aug 23
16:25:48 PDT 2012; root:xnu-1699.32.7~1/RELEASE_X86_64 x86_64
tsunami:~ schappetj$ java -version
java version 1.6.0_51
Java(TM) SE Runtime Environment (build 1.6.0_51-b11-457-11M4509)
Java HotSpot(TM) 64-Bit Server VM (build 20.51-b01-457, mixed mode)
tsunami:~ schappetj$
apache-cassandra-1.2.7-src
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
[jira] [Commented] (CASSANDRA-5813) PIG Error Using CqlStorage
[
https://issues.apache.org/jira/browse/CASSANDRA-5813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=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
[jira] [Commented] (CASSANDRA-5813) PIG Error Using CqlStorage
[
https://issues.apache.org/jira/browse/CASSANDRA-5813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13721191#comment-13721191
]
James Schappet commented on CASSANDRA-5813:
---
bin/cqlsh -3
CREATE SCHEMA schema1 WITH replication ={ 'class' : 'SimpleStrategy',
'replication_factor' : 1 };
CREATE TABLE users (user_id varchar PRIMARY KEY,first varchar,last varchar,age
int);
INSERT INTO users (user_id, first, last, age) VALUES ('jsmith', 'John',
'Smith', 42);
Then Run PIG:
cd examples/pig
bin/pig_cassandra -x local
grunt rows = LOAD 'cql://schema1/users' USING CqlStorage();
grunt dump rows;
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
[jira] [Commented] (CASSANDRA-5813) PIG Error Using CqlStorage
[
https://issues.apache.org/jira/browse/CASSANDRA-5813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13721244#comment-13721244
]
Brandon Williams commented on CASSANDRA-5813:
-
I don't have a problem following the steps (except you're missing a 'use
schema1;') just reproducing the error, which doesn't occur.
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
