incubator-cassandra-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Miguel Angel Martin junquera <mianmarjun.mailingl...@gmail.com>
Subject Re: Undefined name key_alias in selection clause pig 0.11.1 and cassandra 2.0.1
Date Mon, 30 Sep 2013 13:53:39 GMT
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.
miguelangel.martin@brainsins.com



2013/9/30 Miguel Angel Martin junquera <mianmarjun.mailinglist@gmail.com>

>
>
>
> 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.
> miguelangel.martin@brainsins.com
>
>

Mime
View raw message