I have the same issue using cassandraStorage() and other dataset for this
*note*:
the example cql3 datatest are
CREATE TABLE test (
id text PRIMARY KEY,
title text,
age int
);
and insert some dummy data
insert into test (id, title, age) values('1', 'child', 21);
insert into test (id, title, age) values('2', 'support', 21);
insert into test (id, title, age) values('3', 'manager', 31);
insert into test (id, title, age) values('4', 'QA', 41);
insert into test (id, title, age) values('5', 'QA', 30);
insert into test (id, title, age) values('6', 'QA', 30);
Miguel Angel Martín Junquera
Analyst Engineer.
[email protected]
2013/9/30 Miguel Angel Martin junquera <[email protected]>
>
>
>
> hi:
>
>
> I try to test cassandra 2.0.1 and pig 0.11.1
> but always when i try to load any keyspacei have this error:
>
> Example creating a test keyspace and data:
>
>
>
> I have this error:
>
>
>
>
> *grunt> define CqlStorage org.apache.cassandra.hadoop.pig.CqlStorage();*
> *grunt> rows = LOAD 'cql://keyspace0/test' USING
> org.apache.cassandra.hadoop.pig.CqlStorage();*
> *2013-09-30 15:43:09,176 [main] ERROR org.apache.pig.tools.grunt.Grunt -
> ERROR 2999: Unexpected internal error.
> InvalidRequestException(why:Undefined name key_alias in selection clause)*
> *Details at logfile: /private/var/log/pig/logging_pig_0.11.1.log*
>
>
>
>
> and in the log file there are not more info
>
>
>
> Pig Stack Trace
> ---------------
> ERROR 2999: Unexpected internal error.
> InvalidRequestException(why:Undefined name key_alias in selection clause)
>
> java.lang.RuntimeException: InvalidRequestException(why:Undefined name
> key_alias in selection clause)
> at
> org.apache.cassandra.hadoop.pig.AbstractCassandraStorage.initSchema(AbstractCassandraStorage.java:511)
> at
> org.apache.cassandra.hadoop.pig.CqlStorage.setLocation(CqlStorage.java:246)
> at
> org.apache.cassandra.hadoop.pig.CqlStorage.getSchema(CqlStorage.java:280)
> at
> org.apache.pig.newplan.logical.relational.LOLoad.getSchemaFromMetaData(LOLoad.java:151)
> at
> org.apache.pig.newplan.logical.relational.LOLoad.getSchema(LOLoad.java:110)
> at
> org.apache.pig.newplan.logical.visitor.LineageFindRelVisitor.visit(LineageFindRelVisitor.java:100)
> at
> org.apache.pig.newplan.logical.relational.LOLoad.accept(LOLoad.java:219)
> at
> org.apache.pig.newplan.DependencyOrderWalker.walk(DependencyOrderWalker.java:75)
> at org.apache.pig.newplan.PlanVisitor.visit(PlanVisitor.java:50)
> at
> org.apache.pig.newplan.logical.visitor.CastLineageSetter.<init>(CastLineageSetter.java:57)
> at org.apache.pig.PigServer$Graph.compile(PigServer.java:1635)
> at
> org.apache.pig.PigServer$Graph.validateQuery(PigServer.java:1566)
> at
> org.apache.pig.PigServer$Graph.registerQuery(PigServer.java:1538)
> at org.apache.pig.PigServer.registerQuery(PigServer.java:540)
> at
> org.apache.pig.tools.grunt.GruntParser.processPig(GruntParser.java:970)
> at
> org.apache.pig.tools.pigscript.parser.PigScriptParser.parse(PigScriptParser.java:386)
> at
> org.apache.pig.tools.grunt.GruntParser.parseStopOnError(GruntParser.java:189)
> at
> org.apache.pig.tools.grunt.GruntParser.parseStopOnError(GruntParser.java:165)
> at org.apache.pig.tools.grunt.Grunt.run(Grunt.java:69)
> at org.apache.pig.Main.run(Main.java:490)
> at org.apache.pig.Main.main(Main.java:111)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
> at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.lang.reflect.Method.invoke(Method.java:606)
> at org.apache.hadoop.util.RunJar.main(RunJar.java:156)
> Caused by: InvalidRequestException(why:Undefined name key_alias in
> selection clause)
> at
> org.apache.cassandra.thrift.Cassandra$execute_cql3_query_result$execute_cql3_query_resultStandardScheme.read(Cassandra.java:48006)
> at
> org.apache.cassandra.thrift.Cassandra$execute_cql3_query_result$execute_cql3_query_resultStandardScheme.read(Cassandra.java:47983)
> at
> org.apache.cassandra.thrift.Cassandra$execute_cql3_query_result.read(Cassandra.java:47898)
> at
> org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:78)
> at
> org.apache.cassandra.thrift.Cassandra$Client.recv_execute_cql3_query(Cassandra.java:1658)
> at
> org.apache.cassandra.thrift.Cassandra$Client.execute_cql3_query(Cassandra.java:1643)
> at
> org.apache.cassandra.hadoop.pig.AbstractCassandraStorage.getCfDef(AbstractCassandraStorage.java:573)
> at
> org.apache.cassandra.hadoop.pig.AbstractCassandraStorage.initSchema(AbstractCassandraStorage.java:500)
> ... 25 more
>
>
>
>
> any idea?
>
>
> thanks
>
>
>
>
> Miguel Angel Martín Junquera
> Analyst Engineer.
> [email protected]
>
>
