Return-Path: X-Original-To: apmail-cassandra-user-archive@www.apache.org Delivered-To: apmail-cassandra-user-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 1F91B10E57 for ; Wed, 21 Aug 2013 13:27:27 +0000 (UTC) Received: (qmail 17865 invoked by uid 500); 21 Aug 2013 13:27:24 -0000 Delivered-To: apmail-cassandra-user-archive@cassandra.apache.org Received: (qmail 17486 invoked by uid 500); 21 Aug 2013 13:27:18 -0000 Mailing-List: contact user-help@cassandra.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@cassandra.apache.org Delivered-To: mailing list user@cassandra.apache.org Received: (qmail 17478 invoked by uid 99); 21 Aug 2013 13:27:17 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 21 Aug 2013 13:27:17 +0000 X-ASF-Spam-Status: No, hits=0.8 required=5.0 tests=FSL_HELO_BARE_IP_2,RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of srecon@yandex.ru designates 77.88.60.125 as permitted sender) Received: from [77.88.60.125] (HELO forward6.mail.yandex.net) (77.88.60.125) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 21 Aug 2013 13:27:09 +0000 Received: from web5e.yandex.ru (web5e.yandex.ru [77.88.60.74]) by forward6.mail.yandex.net (Yandex) with ESMTP id 2E59711220E7 for ; Wed, 21 Aug 2013 17:26:49 +0400 (MSK) Received: from 127.0.0.1 (localhost.localdomain [127.0.0.1]) by web5e.yandex.ru (Yandex) with ESMTP id 25DFE1278048; Wed, 21 Aug 2013 17:26:47 +0400 (MSK) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=yandex.ru; s=mail; t=1377091608; bh=tXM9RjXBprkj7mWRrcV4t01vCmL+V4neOnRAUWNUrmo=; h=From:To:In-Reply-To:References:Subject:Date; b=GwjRGrmpaceVUjzN0gTchnYlzs8hROB1uW+CSYSKiQhlrkNoFZLu+NOgi4dAUov0O 6WMQmkAjYLWuqbQApenEBbOVbQK0MBLqDaG/O/DcvGFiducH2ARHKEt6SvuC7QATx+ bqNft5B5MlsmAhSVoQOJgPRTya6fAgZpH+7WS5c0= Received: from [91.241.12.28] ([91.241.12.28]) by web5e.yandex.ru with HTTP; Wed, 21 Aug 2013 17:26:45 +0400 From: Shamim To: "user@cassandra.apache.org" In-Reply-To: References: Subject: Re: bug in Pig LOAD with cqlStorage and param columns? - cassandra 1.2.8 - pig 0.11.1 MIME-Version: 1.0 Message-Id: <12001377091605@web5e.yandex.ru> X-Mailer: Yamail [ http://yandex.ru ] 5.0 Date: Wed, 21 Aug 2013 17:26:45 +0400 Content-Transfer-Encoding: 8bit Content-Type: text/plain; charset=koi8-r X-Virus-Checked: Checked by ClamAV on apache.org 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" : > 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 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 };