Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 Search Hadoop and all its subprojects:

Switch to Threaded 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 };
*
*
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB