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.mar...@brainsins.com 2013/9/30 Miguel Angel Martin junquera <mianmarjun.mailingl...@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.mar...@brainsins.com > >