Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 Search Hadoop and all its subprojects:

Switch to Threaded View
Pig >> mail # user >> Undefined name key_alias in selection clause pig 0.11.1 and cassandra 2.0.1


Copy link to this message
-
Re: Undefined name key_alias in selection clause pig 0.11.1 and cassandra 2.0.1
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)
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB