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 }; * *
