You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@cassandra.apache.org by Miguel Angel Martin junquera <mi...@gmail.com> on 2013/08/21 13:49:58 UTC
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 };
*
*
Re: bug in Pig LOAD with cqlStorage and param columns? - cassandra 1.2.8 - pig 0.11.1
Posted by Shamim <sr...@yandex.ru>.
Hello,
When i have tested the issue CASSANDRA-5234, it's work with the following query
rows = LOAD 'cql://keyspace1/test?page_size=1&columns=title,age&split_size=4&where_clause=age%3D30' USING CqlStorage();
there was no problem with param columns. May be something goes wrong with version 1.2.8 - it's better to check the source code of the CqlStorage and in any case reopen the CASSANDRA-5234.
--
Best regards
Shamim A.
21.08.2013, 16:06, "Jeremy Hanna" <je...@gmail.com>:
> In order to narrow down the problem, I would start without the request parameters and see if that works. Then I would add the request parameters one at a time to see what breaks things. Often pig is not very helpful with its error messages, so I've had to use this method a lot.
>
> On 21 Aug 2013, at 12:49, Miguel Angel Martin junquera <mi...@gmail.com> wrote:
>
>> 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 };
Re: bug in Pig LOAD with cqlStorage and param columns? - cassandra 1.2.8 - pig 0.11.1
Posted by Jeremy Hanna <je...@gmail.com>.
In order to narrow down the problem, I would start without the request parameters and see if that works. Then I would add the request parameters one at a time to see what breaks things. Often pig is not very helpful with its error messages, so I've had to use this method a lot.
On 21 Aug 2013, at 12:49, Miguel Angel Martin junquera <mi...@gmail.com> wrote:
> 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 };
>
>