[jira] [Resolved] (PIG-3544) Pig fails to query Apache Cassandra 2.x

["Rohini Palaniswamy (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/PIG-3544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Rohini Palaniswamy resolved PIG-3544.
-------------------------------------
    Resolution: Not A Problem

Closing as it is a bug in Cassandra code base.

> Pig fails to query Apache Cassandra 2.x
> ---------------------------------------
>
>                 Key: PIG-3544
>                 URL: https://issues.apache.org/jira/browse/PIG-3544
>             Project: Pig
>          Issue Type: Bug
>          Components: build
>    Affects Versions: 0.12.0
>         Environment: CentOS 6.4 - 2.6.32-279.19.1.el6.centos.plus.x86_64
>            Reporter: Claudio Romo Otto
>            Priority: Blocker
>
> Using Apache Pig 0.12 with Apache Cassandra 2.x (2.0.0 / 2.0.1),
> with this sample request
> data = LOAD 'cql://keyspace1/testcf?' USING CqlStorage();
> testcf is just any CF
> I get this error:
> 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:212)
> 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



--
This message was sent by Atlassian Jira
(v8.20.10#820010)