incubator-cassandra-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Shamim <sre...@yandex.ru>
Subject Re: bug in Pig LOAD with cqlStorage and param columns? - cassandra 1.2.8 - pig 0.11.1
Date Wed, 21 Aug 2013 13:26:45 GMT
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" <jeremy.hanna1234@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 <mianmarjun.mailinglist@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 };

Mime
View raw message