Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Plain View
Pig >> mail # user >> bug in Pig LOAD with cqlStorage and param columns? - cassandra 1.2.8 - pig 0.11.1


Copy link to this message
-
bug in Pig LOAD with cqlStorage and param columns? - cassandra 1.2.8 - pig 0.11.1
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 };
*
*