incubator-cassandra-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Miguel Angel Martin junquera <mianmarjun.mailingl...@gmail.com>
Subject bug in Pig LOAD with cqlStorage and param columns? - cassandra 1.2.8 - pig 0.11.1
Date Wed, 21 Aug 2013 11:49:58 GMT
hi:

I am using pig 0.11.1 and cassandra 1.2.8.

i try this

http://frommyworkshop.blogspot.com.es/2013/07/hadoop-map-reduce-with-cassandra.html


and...


*rows = LOAD
'cql://keyspace1/test?page_size=1&split_size=4&where_clause=age%3D30' USING
CqlStorage();*
*dump rows;*


 works fine if I skip  the param "columns"  and I create an index :

CREATE INDEX AGE_IDX ON test (age);

But ..... It seems that the param column does not work right.


if I try:

rows = LOAD
'cql://keyspace1/test?page_size=1&columns=title,age&split_size=4&where_clause=age%3D30'
USING CqlStorage();
dump rows;


I have this error:

*Pig Stack Trace*

*---------------*

*ERROR 1066: Unable to open iterator for alias rows*

*
*

*org.apache.pig.impl.logicalLayer.FrontendException: ERROR 1066: Unable to
open iterator for alias rows*

* at org.apache.pig.PigServer.openIterator(PigServer.java:836)*

* at
org.apache.pig.tools.grunt.GruntParser.processDump(GruntParser.java:696)*

* at
org.apache.pig.tools.pigscript.parser.PigScriptParser.parse(PigScriptParser.java:320)
*

* at
org.apache.pig.tools.grunt.GruntParser.parseStopOnError(GruntParser.java:194)
*

* at
org.apache.pig.tools.grunt.GruntParser.parseStopOnError(GruntParser.java:170)
*

* at org.apache.pig.tools.grunt.Grunt.exec(Grunt.java:84)*

* at org.apache.pig.Main.run(Main.java:604)*

* at org.apache.pig.Main.main(Main.java:157)*

*Caused by: java.io.IOException: Job terminated with anomalous status FAILED
*

* at org.apache.pig.PigServer.openIterator(PigServer.java:828)*

* ... 7 more*
*
*
*
*

*I try escape the , chart with =>  columns=title%2Cage*
*
*
*
*
*
*
*but I still have the same error*
*
*
*is this  a bug?*
*
*
*Thanks in advance*
*
*
*note :*
*
*
*I create the keyspace1 with  cqlsh -3 localhost:*
*
*

cqlsh> CREATE KEYSPACE keyspace1   WITH REPLICATION = { 'class' :
'SimpleStrategy', 'replication_factor' : 1 };


*
*

Mime
View raw message