cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Shridhar (JIRA)" <j...@apache.org>
Subject [jira] [Comment Edited] (CASSANDRA-6454) Pig support for hadoop CqlInputFormat
Date Wed, 28 May 2014 15:28:03 GMT

    [ 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)

Mime
View raw message