[prev in list] [next in list] [prev in thread] [next in thread] 

List:       cassandra-commits
Subject:    [jira] [Comment Edited] (CASSANDRA-6513) CqlPaging for hadoop fails when writetime(column_name) is s
From:       "Ala' Alkhaldi (JIRA)" <jira () apache ! org>
Date:       2014-06-30 21:07:25
Message-ID: JIRA.12685678.1387486152400.76041.1404162445152 () arcas
[Download RAW message or body]


    [ https://issues.apache.org/jira/browse/CASSANDRA-6513?page=com.atlassian.jira.plu \
gin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14047988#comment-14047988 \
] 

Ala' Alkhaldi edited comment on CASSANDRA-6513 at 6/30/14 9:07 PM:
-------------------------------------------------------------------

Related to [CASSANDRA-5763|https://issues.apache.org/jira/browse/CASSANDRA-5763] : \
quoting column identifiers makes CQL functions unrecognizable by the select parser. \
Therefore, same issue applies to TTL, token, and other functions.

I suggest reverting back the changes in Cassandra-5763 and relying on the user for \
submitting a correct query.




was (Author: ala.alkhaldi):
Related to [CASSANDRA-5763|https://issues.apache.org/jira/browse/CASSANDRA-5763] : \
quoting column identifiers makes CQL functions unrecognizable by the select parser. \
So same issue applies to TTL, token, and other functions.

> CqlPaging for hadoop fails when writetime(column_name) is set as one of the input \
>                 columns
> -----------------------------------------------------------------------------------------
>  
> Key: CASSANDRA-6513
> URL: https://issues.apache.org/jira/browse/CASSANDRA-6513
> Project: Cassandra
> Issue Type: Bug
> Components: Hadoop
> Environment: ubuntu 12.04, hadoop 1.0.3, cassandra-1.2.13
> Reporter: Sheetal Gosrani
> Labels: CqlPaging, Hadoop
> Fix For: 2.0.10
> 
> 
> InvalidRequestException thrown when running a hadoop job with CqlPaging with \
> writetime(column_name) set as one of the input columns. java.lang.RuntimeException
> at org.apache.cassandra.hadoop.cql3.CqlPagingRecordReader$RowIterator.executeQuery(CqlPagingRecordReader.java:665)
>  at org.apache.cassandra.hadoop.cql3.CqlPagingRecordReader$RowIterator.<init>(CqlPagingRecordReader.java:301)
>  at org.apache.cassandra.hadoop.cql3.CqlPagingRecordReader.initialize(CqlPagingRecordReader.java:167)
>  at org.apache.hadoop.mapred.MapTask$NewTrackingRecordReader.initialize(MapTask.java:522)
>  at org.apache.hadoop.mapred.MapTask.runNewMapper(MapTask.java:763)
> at org.apache.hadoop.mapred.MapTask.run(MapTask.java:370)
> at org.apache.hadoop.mapred.Child$4.run(Child.java:255)
> at java.security.AccessController.doPrivileged(Native Method)
> at javax.security.auth.Subject.doAs(Subject.java:415)
> at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1121)
>  at org.apache.hadoop.mapred.Child.main(Child.java:249)
> Caused by: InvalidRequestException(why:Undefined name WRITETIME(foo) in selection \
> clause) at org.apache.cassandra.thrift.Cassandra$prepare_cql3_query_result.read(Cassandra.java:40395)
>  at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:78)
> at org.apache.cassandra.thrift.Cassandra$Client.recv_prepare_cql3_query(Cassandra.java:1660)
>  at org.apache.cassandra.thrift.Cassandra$Client.prepare_cql3_query(Cassandra.java:1646)
>  at org.apache.cassandra.hadoop.cql3.CqlPagingRecordReader$RowIterator.prepareQuery(CqlPagingRecordReader.java:605)
>  at org.apache.cassandra.hadoop.cql3.CqlPagingRecordReader$RowIterator.executeQuery(CqlPagingRecordReader.java:635)
>                 
> ... 10 more
> The hadoop config lines look as such:
> //read input from cassandra column family using CQL Input Format
> job.setInputFormatClass(CqlPagingInputFormat.class);
> ConfigHelper.setInputColumnFamily(job.getConfiguration(), KEYSPACE, \
> INPUT_COLUMN_FAMILY); ConfigHelper.setInputRpcPort(job.getConfiguration(), "9160");
> ConfigHelper.setInputInitialAddress(job.getConfiguration(), HOST);
> ConfigHelper.setInputPartitioner(job.getConfiguration(), "RandomPartitioner");
> CqlConfigHelper.setInputColumns(job.getConfiguration(), "foo,WRITETIME(foo)");
> job.getConfiguration().set("cassandra.consistencylevel.read", READ_CONSISTENCY);
> CqlConfigHelper.setInputCQLPageRowSize(job.getConfiguration(), "3000");



--
This message was sent by Atlassian JIRA
(v6.2#6252)


[prev in list] [next in list] [prev in thread] [next in thread]