[
https://issues.apache.org/jira/browse/CASSANDRA-6454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14011193#comment-14011193
]
Shridhar edited comment on CASSANDRA-6454 at 5/28/14 3:27 PM:
--------------------------------------------------------------
[~alexliu68] I have applied the new patch. After this am not able to load data
from Cassandra. It throws me an exception
Caused by: InvalidRequestException(why:Keyspace '' does not exist)
at
org.apache.cassandra.thrift.Cassandra$set_keyspace_result$set_keyspace_resultStandardScheme.read(Cassandra.java:8906)
at
org.apache.cassandra.thrift.Cassandra$set_keyspace_result$set_keyspace_resultStandardScheme.read(Cassandra.java:8892)
at
org.apache.cassandra.thrift.Cassandra$set_keyspace_result.read(Cassandra.java:8842)
at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:78)
at
org.apache.cassandra.thrift.Cassandra$Client.recv_set_keyspace(Cassandra.java:599)
at
org.apache.cassandra.thrift.Cassandra$Client.set_keyspace(Cassandra.java:586)
at
org.apache.cassandra.hadoop.pig.AbstractCassandraStorage.initSchema(AbstractCassandraStorage.java:493)
Table schema :
CREATE TABLE dogs (
block_id int,
breed text,
color text,
short_hair boolean,
PRIMARY KEY ((block_id, breed), color, short_hair))
My pig load function would be like this
data = load 'cql://excelsior/dogs' using
org.apache.cassandra.hadoop.pig.CqlNativeStorage();
Also tried with this
a = load 'cql://excelsior/dogs?input_cql=select block_id,breed from
excelsior.dogs where token(block_id,breed) > ? and token(block_id,breed) <= ?
and block_id=5 and breed='Bulldog' ' using
org.apache.cassandra.hadoop.pig.CqlNativeStorage();
Still same exception.
was (Author: shridharb):
[~alexliu68] I have applied the new patch. After this am not able to load data
from Cassandra. It throws me an exception
Caused by: InvalidRequestException(why:Keyspace '' does not exist)
at
org.apache.cassandra.thrift.Cassandra$set_keyspace_result$set_keyspace_resultStandardScheme.read(Cassandra.java:8906)
at
org.apache.cassandra.thrift.Cassandra$set_keyspace_result$set_keyspace_resultStandardScheme.read(Cassandra.java:8892)
at
org.apache.cassandra.thrift.Cassandra$set_keyspace_result.read(Cassandra.java:8842)
at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:78)
at
org.apache.cassandra.thrift.Cassandra$Client.recv_set_keyspace(Cassandra.java:599)
at
org.apache.cassandra.thrift.Cassandra$Client.set_keyspace(Cassandra.java:586)
at
org.apache.cassandra.hadoop.pig.AbstractCassandraStorage.initSchema(AbstractCassandraStorage.java:493)
Table schema :
CREATE TABLE dogs (
block_id int,
breed text,
color text,
short_hair boolean,
PRIMARY KEY ((block_id, breed), color, short_hair))
My pig load function would be like this
data = load 'cql://excelsior/dogs' using
org.apache.cassandra.hadoop.pig.CqlNativeStorage();
Also tried with this
a = load 'cql://excelsior/dogs?input_cql=select block_id,breed from
excelsior.dogs where token(block_id,breed) > ? and token(block_id,breed) <= ?
and block_id=5 and breed='Bulldog' ' using
org.apache.cassandra.hadoop.pig.CqlNativeStorage();
Still same exception. Am i doing something wrong in syntax or ???
> Pig support for hadoop CqlInputFormat
> -------------------------------------
>
> Key: CASSANDRA-6454
> URL: https://issues.apache.org/jira/browse/CASSANDRA-6454
> Project: Cassandra
> Issue Type: Bug
> Components: Hadoop
> Reporter: Alex Liu
> Assignee: Alex Liu
> Fix For: 2.0.9
>
> Attachments: 6454-2.0-branch.txt, 6454-v2-2.0-branch.txt
>
>
> CASSANDRA-6311 adds new CqlInputFormat, we need add the Pig support for it
--
This message was sent by Atlassian JIRA
(v6.2#6252)
