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 DE9FBFFD6 for ; Fri, 5 Apr 2013 14:43:45 +0000 (UTC) Received: (qmail 4094 invoked by uid 500); 5 Apr 2013 14:43:43 -0000 Delivered-To: apmail-cassandra-user-archive@cassandra.apache.org Received: (qmail 4059 invoked by uid 500); 5 Apr 2013 14:43:42 -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 4047 invoked by uid 99); 5 Apr 2013 14:43:42 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 05 Apr 2013 14:43:42 +0000 X-ASF-Spam-Status: No, hits=1.5 required=5.0 tests=HTML_MESSAGE,RCVD_IN_DNSWL_LOW X-Spam-Check-By: apache.org Received-SPF: unknown (nike.apache.org: error in processing during lookup of bryan@appssavvy.com) Received: from [209.85.212.43] (HELO mail-vb0-f43.google.com) (209.85.212.43) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 05 Apr 2013 14:43:34 +0000 Received: by mail-vb0-f43.google.com with SMTP id q12so2170265vbe.16 for ; Fri, 05 Apr 2013 07:43:13 -0700 (PDT) X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=google.com; s=20120113; h=x-received:from:mime-version:content-type:subject:date:in-reply-to :to:references:message-id:x-mailer:x-gm-message-state; bh=Pkp742Z7Dl6F/p+9uxo55HRodLdjzkknWqEpHVMkyK4=; b=G2W9aOH/XoMc0VAdFaM5qAaJKIJl7u6bqpy2lPjxHMKOLM7Ypu0Jz04H7HF5PYmPnM E/ZFvJqVHUbkhVUNYFjuh/4MR8Ac0xTRCrR3254exkVTYlc9byErxo/U5QCAvbeiKvx2 ci2SXBzEL7v9z13Qi9Av1NiGu60n0QHjaPapAOow0xIQtI9EnZ3KKvMiIjgJdyBywnNC wgkl04hGB/wS3GPkBBkbFXsimY9OT//aqHM9PWvAqHBdO7PsonsfBk5+frvnDNABH3c7 qWdR8CunIHNRCetfs+O3qNutT7Qsc3BuMM9eo5831sOqVvdU1e30fjp21aFCXMIDOFW0 O0CQ== X-Received: by 10.52.163.167 with SMTP id yj7mr7045798vdb.25.1365172993281; Fri, 05 Apr 2013 07:43:13 -0700 (PDT) Received: from [10.0.1.86] ([206.217.82.210]) by mx.google.com with ESMTPS id xu4sm14063170vdb.11.2013.04.05.07.43.10 (version=TLSv1 cipher=ECDHE-RSA-RC4-SHA bits=128/128); Fri, 05 Apr 2013 07:43:11 -0700 (PDT) From: Bryan Mime-Version: 1.0 (Apple Message framework v1283) Content-Type: multipart/alternative; boundary="Apple-Mail=_F3489ADB-674C-4A12-8C92-1E369AA7B513" Subject: Re: Pig + cassandra Error ERROR 1070: Could not resolve CassandraStorage Date: Fri, 5 Apr 2013 10:43:11 -0400 In-Reply-To: To: user@cassandra.apache.org References: Message-Id: <5057F8D8-4CDD-4F3D-8C3F-6FE6C92F1BB9@appssavvy.com> X-Mailer: Apple Mail (2.1283) X-Gm-Message-State: ALoCoQkxyG8QR5rPifCnwHCAaM/qSQdm2H/aw4vcuiEAzTUd8wc01iG6zUDIlMpxqwqCeEU3KwII X-Virus-Checked: Checked by ClamAV on apache.org --Apple-Mail=_F3489ADB-674C-4A12-8C92-1E369AA7B513 Content-Transfer-Encoding: quoted-printable Content-Type: text/plain; charset=iso-8859-1 I had the same issue when trying to us Pig 0.11.x. I think the interface = changed on the Pig side. I've stuck with using Pig 0.10.x on Cassandra = (1.1.5). I'm not sure about Cassandra 1.2, but I think it should be = fine. If we need a patch to get newer versions of Pig to work on = Cassandra, how would we incorporate the change? Create a new version of = CassandraStorage or add switches to the code? I'd be willing to = contribute. Bryan On Apr 5, 2013, at 4:07 AM, Miguel Angel Martin junquera wrote: > Hi all: >=20 >=20 > I,m newie at Pig and I need read from cassandra DB, but i have this = error when y I`m trying LOAD anything data from cassandra, for example: >=20 >=20 >=20 > rows =3D LOAD 'cassandra://pygmalion/account' USING = CassandraStorage(); > 2013-04-04 19:33:10,304 [main] ERROR org.apache.pig.tools.grunt.Grunt = - ERROR 1070: Could not resolve CassandraStorage using imports: [, = org.apache.pig.builtin., org.apache.pig.impl.builtin.] > Details at logfile: = /Users/mamartin/Desarrollo/cassandra/apache-cassandra-1.2.0-src/examples/p= ig/bin/pig_1365096786052.log >=20 >=20 > My environmet config Is this: >=20 > mac OX lion > Cassandra 1.2.0=20 > pig 0.11.1 > hadoop 1.1.1 >=20 > 1.- cassandra run OK with two datanode in local in 127.0.0.1 and = 127.0.0.2=20 >=20 > 2.- I`ve create and insert data in columFamilys (Ex: account ) in = pygmalion keystore with casandra_cli and it is ok in Cassandra I=B4m = using opscenter to see data.. >=20 > 3.- I download casandra.1.2.0-src and I check adn the instructions in = README file in the examples/pig/ folder. I run script pig_cassandra = in local with ./pig_casandra -x local (i try too with hadoop and run ok)=20= >=20 > 4 i have the error in load data from cassandra > --------------------------------------- >=20 >=20 > I`m frustated because i revised the documentation from casandra , = pygmalion, i search info at google, stackoverfow, etc but i can find a = solution. >=20 > I saw this blog > = http://frommyworkshop.blogspot.tw/2012/07/single-node-hadoop-cassandra-pig= -setup.html >=20 > but dont works for me. >=20 >=20 > I try to load data with: >=20 > grunt> rows =3D LOAD 'cassandra://pygmalion/account' USING = org.apache.cassandra.hadoop.pig.CassandraStorage(); > 2013-04-04 19:52:13,248 [main] ERROR org.apache.pig.tools.grunt.Grunt = - ERROR 2998: Unhandled internal error. = org/apache/pig/StoreFuncInterface > Details at logfile: = /Users/mamartin/Desarrollo/cassandra/apache-cassandra-1.2.0-src/examples/p= ig/bin/pig_1365096786052.log >=20 >=20 >=20 >=20 > And i catch another error =3D> java.lang.NoClassDefFoundError: = org/apache/pig/StoreFuncInterface >=20 > and if i try any LOAD data from cassandra or file after execute this , = i get always this error , no the first. so i close the pig shell. >=20 >=20 > I`m trying load jars directly in grunt with register like >=20 > grunt> register = /Users/mamartin/Desarrollo/cassandra/apache-cassandra-1.2.0-1/lib/apache-c= assandra-1.2.0.jar >=20 >=20 > but i have the same error >=20 >=20 > I appreciate any help or any idea >=20 > Thanks in advance.. >=20 > PD: >=20 > logs and config is this: >=20 >=20 > =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D > .bash_profile > =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D > export HADOOP_PREFIX=3D/usr/local/Cellar/hadoop/1.1.1/libexec > export JAVA_HOME=3D$(/usr/libexec/java_home) > export PATH=3D$PATH:$HADOOP_HOME/bin > export MAVEN_OPTS=3D"-Xmx1024M -XX:MaxPermSize=3D256M" > export PIG_HOME=3D/Users/mamartin/Desarrollo/pig-0.11.1 > export PIG_CONF_DIR=3D/usr/local/Cellar/hadoop/1.1.1/libexec/conf > export PIG_INITIAL_ADDRESS=3Dlocalhost > export PIG_RPC_PORT=3D9160 > export PIG_PARTITIONER=3Dorg.apache.cassandra.dht.RandomPartitioner >=20 >=20 > =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D > Log > =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D >=20 > Pig Stack Trace > --------------- > ERROR 1070: Could not resolve CassandraStorage using imports: [, = org.apache.pig.builtin., org.apache.pig.impl.builtin.] >=20 > Failed to parse: Pig script failed to parse:=20 > pig script failed to validate: = org.apache.pig.backend.executionengine.ExecException: ERROR 1070: Could = not resolve CassandraStorage using imports: [, org.apache.pig.builtin., = org.apache.pig.impl.builtin.] > at = org.apache.pig.parser.QueryParserDriver.parse(QueryParserDriver.java:191) > at = org.apache.pig.PigServer$Graph.validateQuery(PigServer.java:1571) > at = org.apache.pig.PigServer$Graph.registerQuery(PigServer.java:1544) > at org.apache.pig.PigServer.registerQuery(PigServer.java:516) > at = org.apache.pig.tools.grunt.GruntParser.processPig(GruntParser.java:991) > at = org.apache.pig.tools.pigscript.parser.PigScriptParser.parse(PigScriptParse= r.java:412) > at = org.apache.pig.tools.grunt.GruntParser.parseStopOnError(GruntParser.java:1= 94) > at = org.apache.pig.tools.grunt.GruntParser.parseStopOnError(GruntParser.java:1= 70) > at org.apache.pig.tools.grunt.Grunt.run(Grunt.java:69) > at org.apache.pig.Main.run(Main.java:538) > at org.apache.pig.Main.main(Main.java:157) > at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) > at = sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:= 39) > at = sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorIm= pl.java:25) > at java.lang.reflect.Method.invoke(Method.java:597) > at org.apache.hadoop.util.RunJar.main(RunJar.java:156) > Caused by:=20 > pig script failed to validate: = org.apache.pig.backend.executionengine.ExecException: ERROR 1070: Could = not resolve CassandraStorage using imports: [, org.apache.pig.builtin., = org.apache.pig.impl.builtin.] > at = org.apache.pig.parser.LogicalPlanBuilder.validateFuncSpec(LogicalPlanBuild= er.java:1209) > at = org.apache.pig.parser.LogicalPlanBuilder.buildFuncSpec(LogicalPlanBuilder.= java:1194) > at = org.apache.pig.parser.LogicalPlanGenerator.func_clause(LogicalPlanGenerato= r.java:4766) > at = org.apache.pig.parser.LogicalPlanGenerator.load_clause(LogicalPlanGenerato= r.java:3183) > at = org.apache.pig.parser.LogicalPlanGenerator.op_clause(LogicalPlanGenerator.= java:1315) > at = org.apache.pig.parser.LogicalPlanGenerator.general_statement(LogicalPlanGe= nerator.java:799) > at = org.apache.pig.parser.LogicalPlanGenerator.statement(LogicalPlanGenerator.= java:517) > at = org.apache.pig.parser.LogicalPlanGenerator.query(LogicalPlanGenerator.java= :392) > at = org.apache.pig.parser.QueryParserDriver.parse(QueryParserDriver.java:184) > ... 15 more > Caused by: org.apache.pig.backend.executionengine.ExecException: ERROR = 1070: Could not resolve CassandraStorage using imports: [, = org.apache.pig.builtin., org.apache.pig.impl.builtin.] > at = org.apache.pig.impl.PigContext.resolveClassName(PigContext.java:523) > at = org.apache.pig.parser.LogicalPlanBuilder.validateFuncSpec(LogicalPlanBuild= er.java:1206) > ... 23 more > = =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D= =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D= =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D= =3D=3D=3D=3D=3D > Pig Stack Trace > --------------- > ERROR 2998: Unhandled internal error. = org/apache/pig/StoreFuncInterface >=20 > java.lang.NoClassDefFoundError: org/apache/pig/StoreFuncInterface > at java.lang.ClassLoader.defineClass1(Native Method) > at java.lang.ClassLoader.defineClassCond(ClassLoader.java:631) > at java.lang.ClassLoader.defineClass(ClassLoader.java:615) > at = java.security.SecureClassLoader.defineClass(SecureClassLoader.java:141) > at java.net.URLClassLoader.defineClass(URLClassLoader.java:283) > at java.net.URLClassLoader.access$000(URLClassLoader.java:58) > at java.net.URLClassLoader$1.run(URLClassLoader.java:197) > at java.security.AccessController.doPrivileged(Native Method) > at java.net.URLClassLoader.findClass(URLClassLoader.java:190) > at java.lang.ClassLoader.loadClass(ClassLoader.java:306) > at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) > at java.lang.ClassLoader.loadClass(ClassLoader.java:295) > at java.lang.ClassLoader.loadClass(ClassLoader.java:295) > at java.lang.ClassLoader.loadClass(ClassLoader.java:247) > at java.lang.Class.forName0(Native Method) > at java.lang.Class.forName(Class.java:247) > at = org.apache.pig.impl.PigContext.resolveClassName(PigContext.java:505) > at = org.apache.pig.parser.LogicalPlanBuilder.validateFuncSpec(LogicalPlanBuild= er.java:1206) > at = org.apache.pig.parser.LogicalPlanBuilder.buildFuncSpec(LogicalPlanBuilder.= java:1194) > at = org.apache.pig.parser.LogicalPlanGenerator.func_clause(LogicalPlanGenerato= r.java:4766) > at = org.apache.pig.parser.LogicalPlanGenerator.load_clause(LogicalPlanGenerato= r.java:3183) > at = org.apache.pig.parser.LogicalPlanGenerator.op_clause(LogicalPlanGenerator.= java:1315) > at = org.apache.pig.parser.LogicalPlanGenerator.general_statement(LogicalPlanGe= nerator.java:799) > at = org.apache.pig.parser.LogicalPlanGenerator.statement(LogicalPlanGenerator.= java:517) > at = org.apache.pig.parser.LogicalPlanGenerator.query(LogicalPlanGenerator.java= :392) > at = org.apache.pig.parser.QueryParserDriver.parse(QueryParserDriver.java:184) > at = org.apache.pig.PigServer$Graph.validateQuery(PigServer.java:1571) > at = org.apache.pig.PigServer$Graph.registerQuery(PigServer.java:1544) > at org.apache.pig.PigServer.registerQuery(PigServer.java:516) > at = org.apache.pig.tools.grunt.GruntParser.processPig(GruntParser.java:991) > at = org.apache.pig.tools.pigscript.parser.PigScriptParser.parse(PigScriptParse= r.java:412) > at = org.apache.pig.tools.grunt.GruntParser.parseStopOnError(GruntParser.java:1= 94) > at = org.apache.pig.tools.grunt.GruntParser.parseStopOnError(GruntParser.java:1= 70) > at org.apache.pig.tools.grunt.Grunt.run(Grunt.java:69) > at org.apache.pig.Main.run(Main.java:538) > at org.apache.pig.Main.main(Main.java:157) > at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) > at = sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:= 39) > at = sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorIm= pl.java:25) > at java.lang.reflect.Method.invoke(Method.java:597) > at org.apache.hadoop.util.RunJar.main(RunJar.java:156) > Caused by: java.lang.ClassNotFoundException: = org.apache.pig.StoreFuncInterface > at java.net.URLClassLoader$1.run(URLClassLoader.java:202) > at java.security.AccessController.doPrivileged(Native Method) > at java.net.URLClassLoader.findClass(URLClassLoader.java:190) > at java.lang.ClassLoader.loadClass(ClassLoader.java:306) > at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) > at java.lang.ClassLoader.loadClass(ClassLoader.java:247) > ... 41 more > = =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D= =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D= =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D= =3D=3D=3D=3D=3D > Pig Stack Trace > --------------- > ERROR 2998: Unhandled internal error. = org/apache/pig/StoreFuncInterface >=20 > java.lang.NoClassDefFoundError: org/apache/pig/StoreFuncInterface > at java.lang.ClassLoader.defineClass1(Native Method) > at java.lang.ClassLoader.defineClassCond(ClassLoader.java:631) > at java.lang.ClassLoader.defineClass(ClassLoader.java:615) > at = java.security.SecureClassLoader.defineClass(SecureClassLoader.java:141) > at java.net.URLClassLoader.defineClass(URLClassLoader.java:283) > at java.net.URLClassLoader.access$000(URLClassLoader.java:58) > at java.net.URLClassLoader$1.run(URLClassLoader.java:197) > at java.security.AccessController.doPrivileged(Native Method) > at java.net.URLClassLoader.findClass(URLClassLoader.java:190) > at java.lang.ClassLoader.loadClass(ClassLoader.java:306) > at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) > at java.lang.ClassLoader.loadClass(ClassLoader.java:295) > at java.lang.ClassLoader.loadClass(ClassLoader.java:295) > at java.lang.ClassLoader.loadClass(ClassLoader.java:247) > at java.lang.Class.forName0(Native Method) > at java.lang.Class.forName(Class.java:247) > at = org.apache.pig.impl.PigContext.resolveClassName(PigContext.java:505) > at = org.apache.pig.parser.LogicalPlanBuilder.validateFuncSpec(LogicalPlanBuild= er.java:1206) > at = org.apache.pig.parser.LogicalPlanBuilder.buildFuncSpec(LogicalPlanBuilder.= java:1194) > at = org.apache.pig.parser.LogicalPlanGenerator.func_clause(LogicalPlanGenerato= r.java:4766) > at = org.apache.pig.parser.LogicalPlanGenerator.load_clause(LogicalPlanGenerato= r.java:3183) > at = org.apache.pig.parser.LogicalPlanGenerator.op_clause(LogicalPlanGenerator.= java:1315) > at = org.apache.pig.parser.LogicalPlanGenerator.general_statement(LogicalPlanGe= nerator.java:799) > at = org.apache.pig.parser.LogicalPlanGenerator.statement(LogicalPlanGenerator.= java:517) > at = org.apache.pig.parser.LogicalPlanGenerator.query(LogicalPlanGenerator.java= :392) > at = org.apache.pig.parser.QueryParserDriver.parse(QueryParserDriver.java:184) > at = org.apache.pig.PigServer$Graph.validateQuery(PigServer.java:1571) > at = org.apache.pig.PigServer$Graph.registerQuery(PigServer.java:1544) > at org.apache.pig.PigServer.registerQuery(PigServer.java:516) > at = org.apache.pig.tools.grunt.GruntParser.processPig(GruntParser.java:991) > at = org.apache.pig.tools.pigscript.parser.PigScriptParser.parse(PigScriptParse= r.java:412) > at = org.apache.pig.tools.grunt.GruntParser.parseStopOnError(GruntParser.java:1= 94) > at = org.apache.pig.tools.grunt.GruntParser.parseStopOnError(GruntParser.java:1= 70) > at org.apache.pig.tools.grunt.Grunt.run(Grunt.java:69) > at org.apache.pig.Main.run(Main.java:538) > at org.apache.pig.Main.main(Main.java:157) > at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) > at = sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:= 39) > at = sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorIm= pl.java:25) > at java.lang.reflect.Method.invoke(Method.java:597) > at org.apache.hadoop.util.RunJar.main(RunJar.java:156) > Caused by: java.lang.ClassNotFoundException: = org.apache.pig.StoreFuncInterface > at java.net.URLClassLoader$1.run(URLClassLoader.java:202) > at java.security.AccessController.doPrivileged(Native Method) > at java.net.URLClassLoader.findClass(URLClassLoader.java:190) > at java.lang.ClassLoader.loadClass(ClassLoader.java:306) > at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) > at java.lang.ClassLoader.loadClass(ClassLoader.java:247) > ... 41 more > = =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D= =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D= =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D= =3D=3D=3D=3D=3D > Pig Stack Trace > --------------- > ERROR 2998: Unhandled internal error. = org/apache/pig/StoreFuncInterface >=20 > I modified the pig_cassandra, adding an echo to debug the classpath = variables and when i run pig_cassandra and it seem that the jar is in = classpath . > This is the trace: >=20 >=20 > =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D= =3D=3D=3D=3D=3D=3D >=20 >=20 >=20 >=20 >=20 > ./pig_cassandra -x local > Using /Users/mamartin/Desarrollo/pig-0.11.1/pig.jar. > CLASSPATH:=20 > = :./../../..//lib/antlr-3.2.jar:./../../..//lib/avro-1.4.0-fixes.jar:./../.= ./..//lib/avro-1.4.0-sources-fixes.jar:./../../..//lib/commons-cli-1.1.jar= :./../../..//lib/commons-codec-1.2.jar:./../../..//lib/commons-lang-2.6.ja= r:./../../..//lib/compress-lzf-0.8.4.jar:./../../..//lib/concurrentlinkedh= ashmap-lru-1.3.jar:./../../..//lib/guava-13.0.1.jar:./../../..//lib/high-s= cale-lib-1.1.2.jar:./../../..//lib/jackson-core-asl-1.9.2.jar:./../../..//= lib/jackson-mapper-asl-1.9.2.jar:./../../..//lib/jamm-0.2.5.jar:./../../..= //lib/jline-1.0.jar:./../../..//lib/json-simple-1.1.jar:./../../..//lib/li= bthrift-0.7.0.jar:./../../..//lib/log4j-1.2.16.jar:./../../..//lib/metrics= -core-2.0.3.jar:./../../..//lib/netty-3.5.9.Final.jar:./../../..//lib/serv= let-api-2.5-20081211.jar:./../../..//lib/slf4j-api-1.7.2.jar:./../../..//l= ib/slf4j-log4j12-1.7.2.jar:./../../..//lib/snakeyaml-1.6.jar:./../../..//l= ib/snappy-java-1.0.4.1.jar:./../../..//lib/snaptree-0.1.jar:./../../..//bu= ild/lib/jars/ant-1.6.5.jar:./../../..//build/lib/jars/apache-rat-0.6.jar:.= /../../..//build/lib/jars/apache-rat-core-0.6.jar:./../../..//build/lib/ja= rs/apache-rat-tasks-0.6.jar:./../../..//build/lib/jars/asm-3.2.jar:./../..= /..//build/lib/jars/avro-1.3.2.jar:./../../..//build/lib/jars/commons-bean= utils-1.7.0.jar:./../../..//build/lib/jars/commons-beanutils-core-1.8.0.ja= r:./../../..//build/lib/jars/commons-cli-1.2.jar:./../../..//build/lib/jar= s/commons-codec-1.4.jar:./../../..//build/lib/jars/commons-collections-3.2= .jar:./../../..//build/lib/jars/commons-configuration-1.6.jar:./../../..//= build/lib/jars/commons-digester-1.8.jar:./../../..//build/lib/jars/commons= -el-1.0.jar:./../../..//build/lib/jars/commons-httpclient-3.0.1.jar:./../.= ./..//build/lib/jars/commons-lang-2.4.jar:./../../..//build/lib/jars/commo= ns-logging-1.1.1.jar:./../../..//build/lib/jars/commons-math-2.1.jar:./../= ../..//build/lib/jars/commons-net-1.4.1.jar:./../../..//build/lib/jars/cor= e-3.1.1.jar:./../../..//build/lib/jars/hadoop-core-1.0.3.jar:./../../..//b= uild/lib/jars/hsqldb-1.8.0.10.jar:./../../..//build/lib/jars/jackson-core-= asl-1.0.1.jar:./../../..//build/lib/jars/jackson-mapper-asl-1.0.1.jar:./..= /../..//build/lib/jars/jasper-compiler-5.5.12.jar:./../../..//build/lib/ja= rs/jasper-runtime-5.5.12.jar:./../../..//build/lib/jars/jets3t-0.7.1.jar:.= /../../..//build/lib/jars/jetty-6.1.26.jar:./../../..//build/lib/jars/jett= y-util-6.1.26.jar:./../../..//build/lib/jars/jna-3.2.7.jar:./../../..//bui= ld/lib/jars/jopt-simple-3.2.jar:./../../..//build/lib/jars/jsp-2.1-6.1.14.= jar:./../../..//build/lib/jars/jsp-api-2.1-6.1.14.jar:./../../..//build/li= b/jars/junit-4.6.jar:./../../..//build/lib/jars/kfs-0.3.jar:./../../..//bu= ild/lib/jars/oro-2.0.8.jar:./../../..//build/lib/jars/paranamer-2.2.jar:./= ../../..//build/lib/jars/paranamer-ant-2.1.jar:./../../..//build/lib/jars/= paranamer-generator-2.1.jar:./../../..//build/lib/jars/pig-0.10.0.jar:./..= /../..//build/lib/jars/qdox-1.10.jar:./../../..//build/lib/jars/servlet-ap= i-2.5-20081211.jar:./../../..//build/lib/jars/servlet-api-2.5-6.1.14.jar:.= /../../..//build/lib/jars/slf4j-api-1.5.11.jar:./../../..//build/lib/jars/= xmlenc-0.52.jar:./../../..//build/apache-cassandra-1.2.0-SNAPSHOT.jar:./..= /../..//build/apache-cassandra-clientutil-1.2.0-SNAPSHOT.jar:./../../..//b= uild/apache-cassandra-thrift-1.2.0-SNAPSHOT.jar:/Users/mamartin/Desarrollo= /pig-0.11.1/pig.jar > PIG_CLASSPATH:=20 > = ::./../../..//lib/antlr-3.2.jar:./../../..//lib/avro-1.4.0-fixes.jar:./../= ../..//lib/avro-1.4.0-sources-fixes.jar:./../../..//lib/commons-cli-1.1.ja= r:./../../..//lib/commons-codec-1.2.jar:./../../..//lib/commons-lang-2.6.j= ar:./../../..//lib/compress-lzf-0.8.4.jar:./../../..//lib/concurrentlinked= hashmap-lru-1.3.jar:./../../..//lib/guava-13.0.1.jar:./../../..//lib/high-= scale-lib-1.1.2.jar:./../../..//lib/jackson-core-asl-1.9.2.jar:./../../../= /lib/jackson-mapper-asl-1.9.2.jar:./../../..//lib/jamm-0.2.5.jar:./../../.= .//lib/jline-1.0.jar:./../../..//lib/json-simple-1.1.jar:./../../..//lib/l= ibthrift-0.7.0.jar:./../../..//lib/log4j-1.2.16.jar:./../../..//lib/metric= s-core-2.0.3.jar:./../../..//lib/netty-3.5.9.Final.jar:./../../..//lib/ser= vlet-api-2.5-20081211.jar:./../../..//lib/slf4j-api-1.7.2.jar:./../../..//= lib/slf4j-log4j12-1.7.2.jar:./../../..//lib/snakeyaml-1.6.jar:./../../..//= lib/snappy-java-1.0.4.1.jar:./../../..//lib/snaptree-0.1.jar:./../../..//b= uild/lib/jars/ant-1.6.5.jar:./../../..//build/lib/jars/apache-rat-0.6.jar:= ./../../..//build/lib/jars/apache-rat-core-0.6.jar:./../../..//build/lib/j= ars/apache-rat-tasks-0.6.jar:./../../..//build/lib/jars/asm-3.2.jar:./../.= ./..//build/lib/jars/avro-1.3.2.jar:./../../..//build/lib/jars/commons-bea= nutils-1.7.0.jar:./../../..//build/lib/jars/commons-beanutils-core-1.8.0.j= ar:./../../..//build/lib/jars/commons-cli-1.2.jar:./../../..//build/lib/ja= rs/commons-codec-1.4.jar:./../../..//build/lib/jars/commons-collections-3.= 2.jar:./../../..//build/lib/jars/commons-configuration-1.6.jar:./../../../= /build/lib/jars/commons-digester-1.8.jar:./../../..//build/lib/jars/common= s-el-1.0.jar:./../../..//build/lib/jars/commons-httpclient-3.0.1.jar:./../= ../..//build/lib/jars/commons-lang-2.4.jar:./../../..//build/lib/jars/comm= ons-logging-1.1.1.jar:./../../..//build/lib/jars/commons-math-2.1.jar:./..= /../..//build/lib/jars/commons-net-1.4.1.jar:./../../..//build/lib/jars/co= re-3.1.1.jar:./../../..//build/lib/jars/hadoop-core-1.0.3.jar:./../../..//= build/lib/jars/hsqldb-1.8.0.10.jar:./../../..//build/lib/jars/jackson-core= -asl-1.0.1.jar:./../../..//build/lib/jars/jackson-mapper-asl-1.0.1.jar:./.= ./../..//build/lib/jars/jasper-compiler-5.5.12.jar:./../../..//build/lib/j= ars/jasper-runtime-5.5.12.jar:./../../..//build/lib/jars/jets3t-0.7.1.jar:= ./../../..//build/lib/jars/jetty-6.1.26.jar:./../../..//build/lib/jars/jet= ty-util-6.1.26.jar:./../../..//build/lib/jars/jna-3.2.7.jar:./../../..//bu= ild/lib/jars/jopt-simple-3.2.jar:./../../..//build/lib/jars/jsp-2.1-6.1.14= .jar:./../../..//build/lib/jars/jsp-api-2.1-6.1.14.jar:./../../..//build/l= ib/jars/junit-4.6.jar:./../../..//build/lib/jars/kfs-0.3.jar:./../../..//b= uild/lib/jars/oro-2.0.8.jar:./../../..//build/lib/jars/paranamer-2.2.jar:.= /../../..//build/lib/jars/paranamer-ant-2.1.jar:./../../..//build/lib/jars= /paranamer-generator-2.1.jar:./../../..//build/lib/jars/pig-0.10.0.jar:./.= ./../..//build/lib/jars/qdox-1.10.jar:./../../..//build/lib/jars/servlet-a= pi-2.5-20081211.jar:./../../..//build/lib/jars/servlet-api-2.5-6.1.14.jar:= ./../../..//build/lib/jars/slf4j-api-1.5.11.jar:./../../..//build/lib/jars= /xmlenc-0.52.jar:./../../..//build/apache-cassandra-1.2.0-SNAPSHOT.jar:./.= ./../..//build/apache-cassandra-clientutil-1.2.0-SNAPSHOT.jar:./../../..//= build/apache-cassandra-thrift-1.2.0-SNAPSHOT.jar:/Users/mamartin/Desarroll= o/pig-0.11.1/pig.jar > 2013-04-04 20:01:35,892 [main] INFO org.apache.pig.Main - Apache Pig = version 0.11.2-SNAPSHOT (rexported) compiled abr 03 2013, 17:18:03 > 2013-04-04 20:01:35,892 [main] INFO org.apache.pig.Main - Logging = error messages to: = /Users/mamartin/Desarrollo/cassandra/apache-cassandra-1.2.0-src/examples/p= ig/bin/pig_1365098495890.log > 2013-04-04 20:01:35,912 [main] INFO org.apache.pig.impl.util.Utils - = Default bootup file /Users/mamartin/.pigbootup not found > 2013-04-04 20:01:36,077 [main] INFO = org.apache.pig.backend.hadoop.executionengine.HExecutionEngine - = Connecting to hadoop file system at: file:/// > grunt>=20 --Apple-Mail=_F3489ADB-674C-4A12-8C92-1E369AA7B513 Content-Transfer-Encoding: quoted-printable Content-Type: text/html; charset=iso-8859-1 I had = the same issue when trying to us Pig 0.11.x. I think the interface = changed on the Pig side. I've stuck with using Pig 0.10.x on Cassandra = (1.1.5). I'm not sure about Cassandra 1.2, but I think it should be = fine. If we need a patch to get newer versions of Pig to work on = Cassandra, how would we incorporate the change? Create a new version of = CassandraStorage or add switches to the code? I'd be willing to = contribute.

Bryan


On Apr 5, 2013, at 4:07 AM, Miguel Angel Martin junquera = wrote:

Hi all:


I,m newie at Pig  and I need read from cassandra DB, but i have = this error when y I`m trying LOAD anything data from cassandra, for = example:



rows =3D LOAD 'cassandra://pygmalion/account'= USING CassandraStorage();
2013-04-04 19:33:10,304 [main] ERROR = org.apache.pig.tools.grunt.Grunt - ERROR 1070: Could not resolve = CassandraStorage using imports: [, org.apache.pig.builtin., = org.apache.pig.impl.builtin.]
Details at logfile: = /Users/mamartin/Desarrollo/cassandra/apache-cassandra-1.2.0-src/examples/p= ig/bin/pig_1365096786052.log


My environmet = config Is this:

  • mac OX lion
  • Cassandra 1.2.0 
  • pig 0.11.1
  • hadoop 1.1.1

1.- cassandra run OK with two datanode in local in 127.0.0.1 and = 127.0.0.2 

2.- I`ve create = and insert data in columFamilys (Ex: account ) in  pygmalion = keystore  with casandra_cli  and it is ok in Cassandra I=B4m = using  opscenter to see data..

3.- I download = casandra.1.2.0-src and I check adn the instructions in README file in = the examples/pig/  folder.  I run script pig_cassandra =  in local with ./pig_casandra -x local (i try too with hadoop and = run ok) 

4 i have the error = in load data from cassandra
---------------------------------------


I`m frustated because i revised the documentation from casandra , = pygmalion,   i search info at google, stackoverfow, etc but i can = find a solution.

I saw this = blog

but dont works for = me.


I try to load data = with:

grunt> = rows =3D LOAD 'cassandra://pygmalion/account'= = USING org.apache.cassandra.hadoop.pig.CassandraStorage();
2013-04-04 19:52:13,248 [main] ERROR = org.apache.pig.tools.grunt.Grunt - ERROR 2998: Unhandled internal error. = org/apache/pig/StoreFuncInterface
Details at logfile: = /Users/mamartin/Desarrollo/cassandra/apache-cassandra-1.2.0-src/examples/p= ig/bin/pig_1365096786052.log



<= /div>

And i catch another error  =3D> = java.lang.NoClassDefFoundError: org/apache/pig/StoreFuncInterface

and if i try any LOAD data from cassandra or file = after execute this , i get always this error , no the first. so i close = the pig shell.


I`m trying load jars directly in grunt with register = like

grunt> = register = /Users/mamartin/Desarrollo/cassandra/apache-cassandra-1.2.0-1/lib/apache-c= assandra-1.2.0.jar


but i have the same = error


I appreciate any help or any idea

Thanks in = advance..
=
PD:

 logs and = config is this:


=3D=3D=3D=3D=3D= =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D
.bash_profile
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D= =3D=3D=3D=3D=3D=3D
export = HADOOP_PREFIX=3D/usr/local/Cellar/hadoop/1.1.1/libexec
export = JAVA_HOME=3D$(/usr/libexec/java_home)
export PATH=3D$PATH:$HADOOP_HOME/bin
export = MAVEN_OPTS=3D"-Xmx1024M -XX:MaxPermSize=3D256M"
export = PIG_HOME=3D/Users/mamartin/Desarrollo/pig-0.11.1
export = PIG_CONF_DIR=3D/usr/local/Cellar/hadoop/1.1.1/libexec/conf
export PIG_INITIAL_ADDRESS=3Dlocalhost
export = PIG_RPC_PORT=3D9160
export = PIG_PARTITIONER=3Dorg.apache.cassandra.dht.RandomPartitioner


=3D=3D=3D=3D=3D=3D=3D= =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D
Log
=3D=3D=3D=3D=3D= =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D

Pig = Stack Trace
---------------
ERROR 1070: Could not resolve CassandraStorage using imports: [, = org.apache.pig.builtin., = org.apache.pig.impl.builtin.]

Failed to parse: = Pig script failed to parse: 
<line 1, column 48> = pig script failed to validate: = org.apache.pig.backend.executionengine.ExecException: ERROR 1070: Could = not resolve CassandraStorage using imports: [, org.apache.pig.builtin., = org.apache.pig.impl.builtin.]
at = org.apache.pig.parser.QueryParserDriver.parse(QueryParserDriver.java:191)<= /div>
at = org.apache.pig.PigServer$Graph.validateQuery(PigServer.java:1571)
at = org.apache.pig.PigServer$Graph.registerQuery(PigServer.java:1544)
at = org.apache.pig.PigServer.registerQuery(PigServer.java:516)
at = org.apache.pig.tools.grunt.GruntParser.processPig(GruntParser.java:991)
at = org.apache.pig.tools.pigscript.parser.PigScriptParser.parse(PigScriptParse= r.java:412)
at = org.apache.pig.tools.grunt.GruntParser.parseStopOnError(GruntParser.java:1= 94)
at = org.apache.pig.tools.grunt.GruntParser.parseStopOnError(GruntParser.java:1= 70)
at = org.apache.pig.tools.grunt.Grunt.run(Grunt.java:69)
at = org.apache.pig.Main.run(Main.java:538)
at = org.apache.pig.Main.main(Main.java:157)
at = sun.reflect.NativeMethodAccessorImpl.invoke0(Native = Method)
at = sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:= 39)
at = sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorIm= pl.java:25)
= at java.lang.reflect.Method.invoke(Method.java:597)
at = org.apache.hadoop.util.RunJar.main(RunJar.java:156)
Caused = by: 
<line 1, column 48> pig script failed to = validate: org.apache.pig.backend.executionengine.ExecException: ERROR = 1070: Could not resolve CassandraStorage using imports: [, = org.apache.pig.builtin., org.apache.pig.impl.builtin.]
at = org.apache.pig.parser.LogicalPlanBuilder.validateFuncSpec(LogicalPlanBuild= er.java:1209)
= at = org.apache.pig.parser.LogicalPlanBuilder.buildFuncSpec(LogicalPlanBuilder.= java:1194)
at = org.apache.pig.parser.LogicalPlanGenerator.func_clause(LogicalPlanGenerato= r.java:4766)
= at = org.apache.pig.parser.LogicalPlanGenerator.load_clause(LogicalPlanGenerato= r.java:3183)
at = org.apache.pig.parser.LogicalPlanGenerator.op_clause(LogicalPlanGenerator.= java:1315)
= at = org.apache.pig.parser.LogicalPlanGenerator.general_statement(LogicalPlanGe= nerator.java:799)
at = org.apache.pig.parser.LogicalPlanGenerator.statement(LogicalPlanGenerator.= java:517)
= at = org.apache.pig.parser.LogicalPlanGenerator.query(LogicalPlanGenerator.java= :392)
at = org.apache.pig.parser.QueryParserDriver.parse(QueryParserDriver.java:184)<= /div>
... 15 = more
Caused by: = org.apache.pig.backend.executionengine.ExecException: ERROR 1070: Could = not resolve CassandraStorage using imports: [, org.apache.pig.builtin., = org.apache.pig.impl.builtin.]
at = org.apache.pig.impl.PigContext.resolveClassName(PigContext.java:523)
=
at = org.apache.pig.parser.LogicalPlanBuilder.validateFuncSpec(LogicalPlanBuild= er.java:1206)
... 23 = more
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D= =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D= =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D= =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D
Pig Stack = Trace
---------------
ERROR 2998: Unhandled internal = error. org/apache/pig/StoreFuncInterface

java.lang.NoClassDefFoundError: = org/apache/pig/StoreFuncInterface
at = java.lang.ClassLoader.defineClass1(Native Method)
at = java.lang.ClassLoader.defineClassCond(ClassLoader.java:631)
at = java.lang.ClassLoader.defineClass(ClassLoader.java:615)
at = java.security.SecureClassLoader.defineClass(SecureClassLoader.java:141)
at = java.net.URLClassLoader.defineClass(URLClassLoader.java:283)
at = java.net.URLClassLoader.access$000(URLClassLoader.java:58)
at = java.net.URLClassLoader$1.run(URLClassLoader.java:197)
at = java.security.AccessController.doPrivileged(Native Method)
at = java.net.URLClassLoader.findClass(URLClassLoader.java:190)
at = java.lang.ClassLoader.loadClass(ClassLoader.java:306)
at = sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301)
at = java.lang.ClassLoader.loadClass(ClassLoader.java:295)
at = java.lang.ClassLoader.loadClass(ClassLoader.java:295)
at = java.lang.ClassLoader.loadClass(ClassLoader.java:247)
at = java.lang.Class.forName0(Native Method)
at = java.lang.Class.forName(Class.java:247)
at = org.apache.pig.impl.PigContext.resolveClassName(PigContext.java:505)
=
at = org.apache.pig.parser.LogicalPlanBuilder.validateFuncSpec(LogicalPlanBuild= er.java:1206)
= at = org.apache.pig.parser.LogicalPlanBuilder.buildFuncSpec(LogicalPlanBuilder.= java:1194)
at = org.apache.pig.parser.LogicalPlanGenerator.func_clause(LogicalPlanGenerato= r.java:4766)
= at = org.apache.pig.parser.LogicalPlanGenerator.load_clause(LogicalPlanGenerato= r.java:3183)
at = org.apache.pig.parser.LogicalPlanGenerator.op_clause(LogicalPlanGenerator.= java:1315)
= at = org.apache.pig.parser.LogicalPlanGenerator.general_statement(LogicalPlanGe= nerator.java:799)
at = org.apache.pig.parser.LogicalPlanGenerator.statement(LogicalPlanGenerator.= java:517)
= at = org.apache.pig.parser.LogicalPlanGenerator.query(LogicalPlanGenerator.java= :392)
at = org.apache.pig.parser.QueryParserDriver.parse(QueryParserDriver.java:184)<= /div>
at = org.apache.pig.PigServer$Graph.validateQuery(PigServer.java:1571)
at = org.apache.pig.PigServer$Graph.registerQuery(PigServer.java:1544)
at = org.apache.pig.PigServer.registerQuery(PigServer.java:516)
at = org.apache.pig.tools.grunt.GruntParser.processPig(GruntParser.java:991)
at = org.apache.pig.tools.pigscript.parser.PigScriptParser.parse(PigScriptParse= r.java:412)
at = org.apache.pig.tools.grunt.GruntParser.parseStopOnError(GruntParser.java:1= 94)
at = org.apache.pig.tools.grunt.GruntParser.parseStopOnError(GruntParser.java:1= 70)
at = org.apache.pig.tools.grunt.Grunt.run(Grunt.java:69)
at = org.apache.pig.Main.run(Main.java:538)
at = org.apache.pig.Main.main(Main.java:157)
at = sun.reflect.NativeMethodAccessorImpl.invoke0(Native = Method)
at = sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:= 39)
at = sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorIm= pl.java:25)
= at java.lang.reflect.Method.invoke(Method.java:597)
at = org.apache.hadoop.util.RunJar.main(RunJar.java:156)
Caused by: = java.lang.ClassNotFoundException: = org.apache.pig.StoreFuncInterface
at = java.net.URLClassLoader$1.run(URLClassLoader.java:202)
at = java.security.AccessController.doPrivileged(Native = Method)
at = java.net.URLClassLoader.findClass(URLClassLoader.java:190)
at = java.lang.ClassLoader.loadClass(ClassLoader.java:306)
at = sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301)
at = java.lang.ClassLoader.loadClass(ClassLoader.java:247)
... 41 = more
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D= =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D= =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D= =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D
Pig Stack Trace
---------------
ERROR 2998: = Unhandled internal error. = org/apache/pig/StoreFuncInterface

java.lang.NoCla= ssDefFoundError: org/apache/pig/StoreFuncInterface
at = java.lang.ClassLoader.defineClass1(Native Method)
at = java.lang.ClassLoader.defineClassCond(ClassLoader.java:631)
at = java.lang.ClassLoader.defineClass(ClassLoader.java:615)
at = java.security.SecureClassLoader.defineClass(SecureClassLoader.java:141)
at = java.net.URLClassLoader.defineClass(URLClassLoader.java:283)
at = java.net.URLClassLoader.access$000(URLClassLoader.java:58)
at = java.net.URLClassLoader$1.run(URLClassLoader.java:197)
at = java.security.AccessController.doPrivileged(Native Method)
at = java.net.URLClassLoader.findClass(URLClassLoader.java:190)
at = java.lang.ClassLoader.loadClass(ClassLoader.java:306)
at = sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301)
at = java.lang.ClassLoader.loadClass(ClassLoader.java:295)
at = java.lang.ClassLoader.loadClass(ClassLoader.java:295)
at = java.lang.ClassLoader.loadClass(ClassLoader.java:247)
at = java.lang.Class.forName0(Native Method)
at = java.lang.Class.forName(Class.java:247)
at = org.apache.pig.impl.PigContext.resolveClassName(PigContext.java:505)
=
at = org.apache.pig.parser.LogicalPlanBuilder.validateFuncSpec(LogicalPlanBuild= er.java:1206)
= at = org.apache.pig.parser.LogicalPlanBuilder.buildFuncSpec(LogicalPlanBuilder.= java:1194)
at = org.apache.pig.parser.LogicalPlanGenerator.func_clause(LogicalPlanGenerato= r.java:4766)
= at = org.apache.pig.parser.LogicalPlanGenerator.load_clause(LogicalPlanGenerato= r.java:3183)
at = org.apache.pig.parser.LogicalPlanGenerator.op_clause(LogicalPlanGenerator.= java:1315)
= at = org.apache.pig.parser.LogicalPlanGenerator.general_statement(LogicalPlanGe= nerator.java:799)
at = org.apache.pig.parser.LogicalPlanGenerator.statement(LogicalPlanGenerator.= java:517)
= at = org.apache.pig.parser.LogicalPlanGenerator.query(LogicalPlanGenerator.java= :392)
at = org.apache.pig.parser.QueryParserDriver.parse(QueryParserDriver.java:184)<= /div>
at = org.apache.pig.PigServer$Graph.validateQuery(PigServer.java:1571)
at = org.apache.pig.PigServer$Graph.registerQuery(PigServer.java:1544)
at = org.apache.pig.PigServer.registerQuery(PigServer.java:516)
at = org.apache.pig.tools.grunt.GruntParser.processPig(GruntParser.java:991)
at = org.apache.pig.tools.pigscript.parser.PigScriptParser.parse(PigScriptParse= r.java:412)
at = org.apache.pig.tools.grunt.GruntParser.parseStopOnError(GruntParser.java:1= 94)
at = org.apache.pig.tools.grunt.GruntParser.parseStopOnError(GruntParser.java:1= 70)
at = org.apache.pig.tools.grunt.Grunt.run(Grunt.java:69)
at = org.apache.pig.Main.run(Main.java:538)
at = org.apache.pig.Main.main(Main.java:157)
at = sun.reflect.NativeMethodAccessorImpl.invoke0(Native = Method)
at = sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:= 39)
at = sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorIm= pl.java:25)
= at java.lang.reflect.Method.invoke(Method.java:597)
at = org.apache.hadoop.util.RunJar.main(RunJar.java:156)
Caused by: = java.lang.ClassNotFoundException: = org.apache.pig.StoreFuncInterface
at = java.net.URLClassLoader$1.run(URLClassLoader.java:202)
at = java.security.AccessController.doPrivileged(Native = Method)
at = java.net.URLClassLoader.findClass(URLClassLoader.java:190)
at = java.lang.ClassLoader.loadClass(ClassLoader.java:306)
at = sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301)
at = java.lang.ClassLoader.loadClass(ClassLoader.java:247)
... 41 = more
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D= =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D= =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D= =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D
Pig Stack Trace
---------------
ERROR 2998: = Unhandled internal error. = org/apache/pig/StoreFuncInterface

I modified the = pig_cassandra, adding an echo to debug the classpath variables  and = when i run pig_cassandra  and it seem that the jar is in classpath = .
This is the = trace:


=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D= =3D=3D=3D=3D=3D





./pig_cassandra -x = local
Using = /Users/mamartin/Desarrollo/pig-0.11.1/pig.jar.
 CLASSPATH:&= nbsp;
:./../../..//lib/antlr-3.2.jar:./../../..//lib/avro-1.4.0-= fixes.jar:./../../..//lib/avro-1.4.0-sources-fixes.jar:./../../..//lib/com= mons-cli-1.1.jar:./../../..//lib/commons-codec-1.2.jar:./../../..//lib/com= mons-lang-2.6.jar:./../../..//lib/compress-lzf-0.8.4.jar:./../../..//lib/c= oncurrentlinkedhashmap-lru-1.3.jar:./../../..//lib/guava-13.0.1.jar:./../.= ./..//lib/high-scale-lib-1.1.2.jar:./../../..//lib/jackson-core-asl-1.9.2.= jar:./../../..//lib/jackson-mapper-asl-1.9.2.jar:./../../..//lib/jamm-0.2.= 5.jar:./../../..//lib/jline-1.0.jar:./../../..//lib/json-simple-1.1.jar:./= ../../..//lib/libthrift-0.7.0.jar:./../../..//lib/log4j-1.2.16.jar:./../..= /..//lib/metrics-core-2.0.3.jar:./../../..//lib/netty-3.5.9.Final.jar:./..= /../..//lib/servlet-api-2.5-20081211.jar:./../../..//lib/slf4j-api-1.7.2.j= ar:./../../..//lib/slf4j-log4j12-1.7.2.jar:./../../..//lib/snakeyaml-1.6.j= ar:./../../..//lib/snappy-java-1.0.4.1.jar:./../../..//lib/snaptree-0.1.ja= r:./../../..//build/lib/jars/ant-1.6.5.jar:./../../..//build/lib/jars/apac= he-rat-0.6.jar:./../../..//build/lib/jars/apache-rat-core-0.6.jar:./../../= ..//build/lib/jars/apache-rat-tasks-0.6.jar:./../../..//build/lib/jars/asm= -3.2.jar:./../../..//build/lib/jars/avro-1.3.2.jar:./../../..//build/lib/j= ars/commons-beanutils-1.7.0.jar:./../../..//build/lib/jars/commons-beanuti= ls-core-1.8.0.jar:./../../..//build/lib/jars/commons-cli-1.2.jar:./../../.= .//build/lib/jars/commons-codec-1.4.jar:./../../..//build/lib/jars/commons= -collections-3.2.jar:./../../..//build/lib/jars/commons-configuration-1.6.= jar:./../../..//build/lib/jars/commons-digester-1.8.jar:./../../..//build/= lib/jars/commons-el-1.0.jar:./../../..//build/lib/jars/commons-httpclient-= 3.0.1.jar:./../../..//build/lib/jars/commons-lang-2.4.jar:./../../..//buil= d/lib/jars/commons-logging-1.1.1.jar:./../../..//build/lib/jars/commons-ma= th-2.1.jar:./../../..//build/lib/jars/commons-net-1.4.1.jar:./../../..//bu= ild/lib/jars/core-3.1.1.jar:./../../..//build/lib/jars/hadoop-core-1.0.3.j= ar:./../../..//build/lib/jars/hsqldb-1.8.0.10.jar:./../../..//build/lib/ja= rs/jackson-core-asl-1.0.1.jar:./../../..//build/lib/jars/jackson-mapper-as= l-1.0.1.jar:./../../..//build/lib/jars/jasper-compiler-5.5.12.jar:./../../= ..//build/lib/jars/jasper-runtime-5.5.12.jar:./../../..//build/lib/jars/je= ts3t-0.7.1.jar:./../../..//build/lib/jars/jetty-6.1.26.jar:./../../..//bui= ld/lib/jars/jetty-util-6.1.26.jar:./../../..//build/lib/jars/jna-3.2.7.jar= :./../../..//build/lib/jars/jopt-simple-3.2.jar:./../../..//build/lib/jars= /jsp-2.1-6.1.14.jar:./../../..//build/lib/jars/jsp-api-2.1-6.1.14.jar:./..= /../..//build/lib/jars/junit-4.6.jar:./../../..//build/lib/jars/kfs-0.3.ja= r:./../../..//build/lib/jars/oro-2.0.8.jar:./../../..//build/lib/jars/para= namer-2.2.jar:./../../..//build/lib/jars/paranamer-ant-2.1.jar:./../../../= /build/lib/jars/paranamer-generator-2.1.jar:./../../..//build/lib/jars/pig= -0.10.0.jar:./../../..//build/lib/jars/qdox-1.10.jar:./../../..//build/lib= /jars/servlet-api-2.5-20081211.jar:./../../..//build/lib/jars/servlet-api-= 2.5-6.1.14.jar:./../../..//build/lib/jars/slf4j-api-1.5.11.jar:./../../../= /build/lib/jars/xmlenc-0.52.jar:./../../..//build/apache-cassandra-1.2.0-S= NAPSHOT.jar:./../../..//build/apache-cassandra-clientutil-1.2.0-SNAPSHOT.j= ar:./../../..//build/apache-cassandra-thrift-1.2.0-SNAPSHOT.jar:/Users/mam= artin/Desarrollo/pig-0.11.1/pig.jar
=
 PIG_CLASSPATH: 
::./../../..//lib/antlr-3.2.jar:= ./../../..//lib/avro-1.4.0-fixes.jar:./../../..//lib/avro-1.4.0-sources-fi= xes.jar:./../../..//lib/commons-cli-1.1.jar:./../../..//lib/commons-codec-= 1.2.jar:./../../..//lib/commons-lang-2.6.jar:./../../..//lib/compress-lzf-= 0.8.4.jar:./../../..//lib/concurrentlinkedhashmap-lru-1.3.jar:./../../..//= lib/guava-13.0.1.jar:./../../..//lib/high-scale-lib-1.1.2.jar:./../../..//= lib/jackson-core-asl-1.9.2.jar:./../../..//lib/jackson-mapper-asl-1.9.2.ja= r:./../../..//lib/jamm-0.2.5.jar:./../../..//lib/jline-1.0.jar:./../../../= /lib/json-simple-1.1.jar:./../../..//lib/libthrift-0.7.0.jar:./../../..//l= ib/log4j-1.2.16.jar:./../../..//lib/metrics-core-2.0.3.jar:./../../..//lib= /netty-3.5.9.Final.jar:./../../..//lib/servlet-api-2.5-20081211.jar:./../.= ./..//lib/slf4j-api-1.7.2.jar:./../../..//lib/slf4j-log4j12-1.7.2.jar:./..= /../..//lib/snakeyaml-1.6.jar:./../../..//lib/snappy-java-1.0.4.1.jar:./..= /../..//lib/snaptree-0.1.jar:./../../..//build/lib/jars/ant-1.6.5.jar:./..= /../..//build/lib/jars/apache-rat-0.6.jar:./../../..//build/lib/jars/apach= e-rat-core-0.6.jar:./../../..//build/lib/jars/apache-rat-tasks-0.6.jar:./.= ./../..//build/lib/jars/asm-3.2.jar:./../../..//build/lib/jars/avro-1.3.2.= jar:./../../..//build/lib/jars/commons-beanutils-1.7.0.jar:./../../..//bui= ld/lib/jars/commons-beanutils-core-1.8.0.jar:./../../..//build/lib/jars/co= mmons-cli-1.2.jar:./../../..//build/lib/jars/commons-codec-1.4.jar:./../..= /..//build/lib/jars/commons-collections-3.2.jar:./../../..//build/lib/jars= /commons-configuration-1.6.jar:./../../..//build/lib/jars/commons-digester= -1.8.jar:./../../..//build/lib/jars/commons-el-1.0.jar:./../../..//build/l= ib/jars/commons-httpclient-3.0.1.jar:./../../..//build/lib/jars/commons-la= ng-2.4.jar:./../../..//build/lib/jars/commons-logging-1.1.1.jar:./../../..= //build/lib/jars/commons-math-2.1.jar:./../../..//build/lib/jars/commons-n= et-1.4.1.jar:./../../..//build/lib/jars/core-3.1.1.jar:./../../..//build/l= ib/jars/hadoop-core-1.0.3.jar:./../../..//build/lib/jars/hsqldb-1.8.0.10.j= ar:./../../..//build/lib/jars/jackson-core-asl-1.0.1.jar:./../../..//build= /lib/jars/jackson-mapper-asl-1.0.1.jar:./../../..//build/lib/jars/jasper-c= ompiler-5.5.12.jar:./../../..//build/lib/jars/jasper-runtime-5.5.12.jar:./= ../../..//build/lib/jars/jets3t-0.7.1.jar:./../../..//build/lib/jars/jetty= -6.1.26.jar:./../../..//build/lib/jars/jetty-util-6.1.26.jar:./../../..//b= uild/lib/jars/jna-3.2.7.jar:./../../..//build/lib/jars/jopt-simple-3.2.jar= :./../../..//build/lib/jars/jsp-2.1-6.1.14.jar:./../../..//build/lib/jars/= jsp-api-2.1-6.1.14.jar:./../../..//build/lib/jars/junit-4.6.jar:./../../..= //build/lib/jars/kfs-0.3.jar:./../../..//build/lib/jars/oro-2.0.8.jar:./..= /../..//build/lib/jars/paranamer-2.2.jar:./../../..//build/lib/jars/parana= mer-ant-2.1.jar:./../../..//build/lib/jars/paranamer-generator-2.1.jar:./.= ./../..//build/lib/jars/pig-0.10.0.jar:./../../..//build/lib/jars/qdox-1.1= 0.jar:./../../..//build/lib/jars/servlet-api-2.5-20081211.jar:./../../..//= build/lib/jars/servlet-api-2.5-6.1.14.jar:./../../..//build/lib/jars/slf4j= -api-1.5.11.jar:./../../..//build/lib/jars/xmlenc-0.52.jar:./../../..//bui= ld/apache-cassandra-1.2.0-SNAPSHOT.jar:./../../..//build/apache-cassandra-= clientutil-1.2.0-SNAPSHOT.jar:./../../..//build/apache-cassandra-thrift-1.= 2.0-SNAPSHOT.jar:/Users/mamartin/Desarrollo/pig-0.11.1/pig.jar
2013-04-04 20:01:35,892 [main] INFO  org.apache.pig.Main - = Apache Pig version 0.11.2-SNAPSHOT (rexported) compiled abr 03 2013, = 17:18:03
2013-04-04 20:01:35,892 [main] INFO =  org.apache.pig.Main - Logging error messages to: = /Users/mamartin/Desarrollo/cassandra/apache-cassandra-1.2.0-src/examples/p= ig/bin/pig_1365098495890.log
2013-04-04 20:01:35,912 [main] INFO =  org.apache.pig.impl.util.Utils - Default bootup file = /Users/mamartin/.pigbootup not found
2013-04-04 20:01:36,077 = [main] INFO =  org.apache.pig.backend.hadoop.executionengine.HExecutionEngine - = Connecting to hadoop file system at: file:///
grunt> 

= --Apple-Mail=_F3489ADB-674C-4A12-8C92-1E369AA7B513--