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
-
Undefined name key_alias in selection clause pig 0.11.1 and cassandra 2.0.1
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]
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