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 5D223F0A2 for ; Tue, 9 Apr 2013 16:27:04 +0000 (UTC) Received: (qmail 32574 invoked by uid 500); 9 Apr 2013 16:27:01 -0000 Delivered-To: apmail-cassandra-user-archive@cassandra.apache.org Received: (qmail 32496 invoked by uid 500); 9 Apr 2013 16:27:01 -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 32488 invoked by uid 99); 9 Apr 2013 16:27:01 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 09 Apr 2013 16:27:01 +0000 X-ASF-Spam-Status: No, hits=1.5 required=5.0 tests=HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of mianmarjun.mailinglist@gmail.com designates 209.85.215.53 as permitted sender) Received: from [209.85.215.53] (HELO mail-la0-f53.google.com) (209.85.215.53) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 09 Apr 2013 16:26:56 +0000 Received: by mail-la0-f53.google.com with SMTP id fp12so3784963lab.12 for ; Tue, 09 Apr 2013 09:26:34 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:x-received:in-reply-to:references:date:message-id :subject:from:to:content-type; bh=l9lVPlC7yVgaUd9XyGWi9MOo5xWk9PZg/PZzFTy+FbU=; b=zgyHbr+rMc9E/FLUpLCbO5QPo3TpLZCpnfNU1VdQGH7eBJLUJNiSQt4sG+7r7y/M+N Q8P0Nfq1xs4Ya28OvBYocHUs/zPdNHSJ/T+WVKZAvdN3g3xf2j86/fKwSLaMA6Gqr3Bo UsXsBcWQbLbUhJaNpgGK/GS5zXZxqBNlzzEVxsXV0BGBziX+MhWAE1mxP+uOoKhUiMkT TZJPJ9TpOIrpwHNyJLxmgeL0QKNEoNbBLMD6xSKeagVlvldzz8K8VXlHND9ZyKhfxX8n 4icVpsGWI1U6X1zRqXZLmKrWsykiVTFf88pfFyamdlOqLlWe6QmB7D3x98xUDUJhbmgl 7gCw== MIME-Version: 1.0 X-Received: by 10.112.173.70 with SMTP id bi6mr5746970lbc.116.1365524794481; Tue, 09 Apr 2013 09:26:34 -0700 (PDT) Received: by 10.114.200.20 with HTTP; Tue, 9 Apr 2013 09:26:34 -0700 (PDT) In-Reply-To: <29310_1365437105_5162EAB0_29310_3312_1_6F86AB1D-FA64-450A-A1F5-ED19FBD0721D@orange.com> References: <5057F8D8-4CDD-4F3D-8C3F-6FE6C92F1BB9@appssavvy.com> <12266_1365175478_515EECB6_12266_2458_1_E282DB89-B4FF-4C0F-B481-5101EF414DD5@orange.com> <29310_1365437105_5162EAB0_29310_3312_1_6F86AB1D-FA64-450A-A1F5-ED19FBD0721D@orange.com> Date: Tue, 9 Apr 2013 18:26:34 +0200 Message-ID: Subject: Re: Pig + cassandra Error ERROR 1070: Could not resolve CassandraStorage From: Miguel Angel Martin junquera To: user@cassandra.apache.org Content-Type: multipart/alternative; boundary=001a11c261d84ea06804d9f00468 X-Virus-Checked: Checked by ClamAV on apache.org --001a11c261d84ea06804d9f00468 Content-Type: text/plain; charset=ISO-8859-1 Content-Transfer-Encoding: quoted-printable hi cscetbon!!! thanks for your reply ... Yes, i use pig_cassandra, ad yes it,s like a shell script that loads libraries from Cassandra (prefer cassandra -src ) distro with folders build/lib/jar and otherts pat= hs of libs and set PIG_CLASSPATH and PIG_OPTS like you write. And like i told before i chek that the libs are load and i try to include un grunt shell with require . I cheked that the classes that is failing ( java.lang.NoClassDefFoundError) are in jars - Cassandrastorage in *apache-cassandra-1.2.0.jar* - StoreFuncInterface in pig.jar * * * * i=B4ll try your option ... it=B4s sound good !!!! i didn=B4t hope that this issue (load data from cassandra in tuples pig ) take me so time as it. First I try to develop and install in local to scale it to EC2 where i have install hadoop, cassandra ring , etc... Now i connect Cassandra with PIG in a in a cludera CD4 virtualmachine and Its works....well, ... , I dont have the error of load cassandraStorage but i can`t read data from the table () i have no records from cassandra when i load a CF i don,t want to use this environment and version of hadoop, etc.. I am grateful for any help I can ge Regards 2013/4/8 > Are you using pig_cassandra ? its role is to add cassandra classes that > Pig needs to find classes like CassandraStorage. Here is my commandline i= t > uses : > > exec > /Library/Java/JavaVirtualMachines/jdk1.7.0_09.jdk/Contents/Home/bin/java > -Xmx1000m -Dudf.import.list=3Dorg.apache.cassandra.hadoop.pig > -Dpig.log.dir=3D/usr/local/bin/../Cellar/pig/0.11.0/bin/../logs > -Dpig.log.file=3Dpig.log > -Dpig.home.dir=3D/usr/local/bin/../Cellar/pig/0.11.0/bin/.. -classpath > ':/Library/Java/JavaVirtualMachines/jdk1.7.0_09.jdk/Contents/Home/lib/too= ls.jar:::/usr/local/Cellar/cassandra/1.2.3/*:/usr/local/Cellar/pig/0.11.0/p= ig-0.11.0.jar:/usr/local/bin/../Cellar/pig/0.11.0/bin/../pig-0.11.0.jar' > org.apache.pig.Main /Users/cyril/tmp/example-script.pig > > FYI, there is the following line in pig_cassandra that allows us to not > use the whole prefixed name for CassandraStorage : > > export PIG_OPTS=3D"$PIG_OPTS > -Dudf.import.list=3Dorg.apache.cassandra.hadoop.pig" > > > -- > Cyril SCETBON > > On Apr 5, 2013, at 7:00 PM, Miguel Angel Martin junquera < > mianmarjun.mailinglist@gmail.com> wrote: > > expothanks for the reply > > please .... > > can you explain how do you config your environtment....???? > > > > > > Like you see, when I print classpath that export in pig_cassandra after > call ... and I saw that class is in the jar > > I still have this error and i tried with casandra-src and build and pig > 0.10 too. > > > 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: * > * pig script failed to validate: > org.apache.pig.backend.executionengine.ExecException: ERROR 1070: Could n= ot > resolve CassandraStorage using imports: [, org.apache.pig.builtin., > org.apache.pig.impl.builtin.]* > * at > org.apache.pig.parser.QueryParserDriver.parse(QueryParserDriver.java:191)= * > > > > > and also with the issue > > grunt> rows =3D LOAD 'cassandra://Keyspace1/Users' USING > org.apache.cassandra.hadoop.pig.CassandraStorage() AS (key, columns: bag > {T: tuple(name, value)}); > 2013-04-05 18:16:45,118 [main] ERROR org.apache.pig.tools.grunt.Grunt - > ERROR *2998*: Unhandled internal error. org/apache/pig/*StoreFuncInterfac= e > * > * > * > this class is in pig.jar that load in PIG_CLASSPATH like that i can see i= n > the trace log > .... > > * > * > * PIG_CLASSPATH: * > * > ::./../../..//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.ja= r:./../../..//lib/compress-lzf-0.8.4.jar:./../../..//lib/concurrentlinkedha= shmap-lru-1.3.jar:./../../..//lib/guava-13.0.1.jar:./../../..//lib/high-sca= le-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:./../../..//li= b/jline-1.0.jar:./../../..//lib/json-simple-1.1.jar:./../../..//lib/libthri= ft-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.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/ja= rs/ant-1.6.5.jar:./../../..//build/lib/jars/apache-rat-0.6.jar:./../../..//= build/lib/jars/apache-rat-core-0.6.jar:./../../..//build/lib/jars/apache-ra= t-tasks-0.6.jar:./../../..//build/lib/jars/asm-3.2.jar:./../../..//build/li= b/jars/avro-1.3.2.jar:./../../..//build/lib/jars/commons-beanutils-1.7.0.ja= r:./../../..//build/lib/jars/commons-beanutils-core-1.8.0.jar:./../../..//b= uild/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/com= mons-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/commons-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/core-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/jas= per-compiler-5.5.12.jar:./../../..//build/lib/jars/jasper-runtime-5.5.12.ja= r:./../../..//build/lib/jars/jets3t-0.7.1.jar:./../../..//build/lib/jars/je= tty-6.1.26.jar:./../../..//build/lib/jars/jetty-util-6.1.26.jar:./../../../= /build/lib/jars/jna-3.2.7.jar:./../../..//build/lib/jars/jopt-simple-3.2.ja= r:./../../..//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/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/apach= e-cassandra-1.2.0-SNAPSHOT.jar:./../../..//build/apache-cassandra-clientuti= l-1.2.0-SNAPSHOT.jar:./../../..//build/apache-cassandra-thrift-1.2.0-SNAPSH= OT.jar:/Users/mamartin/Desarrollo/pig-0.10.0/pig.jar > * > * > * > * > * > now in classpath i put pig-0.10.0 that i trying to testing with > cassandra-1.2.0 and i deifne the PIG_HOME in .bash_profile to this versio= n. > This is the PIG version that use cassandra 1.2.0 > but i have the same error.... > > > *I also export cassandra jars in the hadoop-env.sh. **And I have this > issues with and without hadoop .* > * > * > * > * > * > * > * > * > > > 2013/4/5 > >> It works for me with cassandra 1.2.2 and Pig 0.11.0 >> -- >> Cyril SCETBON >> >> On Apr 5, 2013, at 4:43 PM, Bryan wrote: >> >> 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, ho= w >> would we incorporate the change? Create a new version of CassandraStorag= e >> 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= /pig/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 i= n >> 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 >> >> http://frommyworkshop.blogspot.tw/2012/07/single-node-hadoop-cassandra-p= ig-setup.html >> >> 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= /pig/bin/pig_1365096786052.log >> >> >> >> >> 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= -cassandra-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: >> 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(PigScriptPar= ser.java:412) >> 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.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.jav= a:39) >> at >> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessor= Impl.java:25) >> at java.lang.reflect.Method.invoke(Method.java:597) >> at org.apache.hadoop.util.RunJar.main(RunJar.java:156) >> Caused by: >> 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(LogicalPlanBui= lder.java:1209) >> at >> org.apache.pig.parser.LogicalPlanBuilder.buildFuncSpec(LogicalPlanBuilde= r.java:1194) >> at >> org.apache.pig.parser.LogicalPlanGenerator.func_clause(LogicalPlanGenera= tor.java:4766) >> at >> org.apache.pig.parser.LogicalPlanGenerator.load_clause(LogicalPlanGenera= tor.java:3183) >> at >> org.apache.pig.parser.LogicalPlanGenerator.op_clause(LogicalPlanGenerato= r.java:1315) >> at >> org.apache.pig.parser.LogicalPlanGenerator.general_statement(LogicalPlan= Generator.java:799) >> at >> org.apache.pig.parser.LogicalPlanGenerator.statement(LogicalPlanGenerato= r.java:517) >> at >> org.apache.pig.parser.LogicalPlanGenerator.query(LogicalPlanGenerator.ja= va: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(LogicalPlanBui= lder.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:14= 1) >> 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(LogicalPlanBui= lder.java:1206) >> at >> org.apache.pig.parser.LogicalPlanBuilder.buildFuncSpec(LogicalPlanBuilde= r.java:1194) >> at >> org.apache.pig.parser.LogicalPlanGenerator.func_clause(LogicalPlanGenera= tor.java:4766) >> at >> org.apache.pig.parser.LogicalPlanGenerator.load_clause(LogicalPlanGenera= tor.java:3183) >> at >> org.apache.pig.parser.LogicalPlanGenerator.op_clause(LogicalPlanGenerato= r.java:1315) >> at >> org.apache.pig.parser.LogicalPlanGenerator.general_statement(LogicalPlan= Generator.java:799) >> at >> org.apache.pig.parser.LogicalPlanGenerator.statement(LogicalPlanGenerato= r.java:517) >> at >> org.apache.pig.parser.LogicalPlanGenerator.query(LogicalPlanGenerator.ja= va: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(PigScriptPar= ser.java:412) >> 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.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.jav= a:39) >> at >> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessor= Impl.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.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:14= 1) >> 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(LogicalPlanBui= lder.java:1206) >> at >> org.apache.pig.parser.LogicalPlanBuilder.buildFuncSpec(LogicalPlanBuilde= r.java:1194) >> at >> org.apache.pig.parser.LogicalPlanGenerator.func_clause(LogicalPlanGenera= tor.java:4766) >> at >> org.apache.pig.parser.LogicalPlanGenerator.load_clause(LogicalPlanGenera= tor.java:3183) >> at >> org.apache.pig.parser.LogicalPlanGenerator.op_clause(LogicalPlanGenerato= r.java:1315) >> at >> org.apache.pig.parser.LogicalPlanGenerator.general_statement(LogicalPlan= Generator.java:799) >> at >> org.apache.pig.parser.LogicalPlanGenerator.statement(LogicalPlanGenerato= r.java:517) >> at >> org.apache.pig.parser.LogicalPlanGenerator.query(LogicalPlanGenerator.ja= va: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(PigScriptPar= ser.java:412) >> 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.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.jav= a:39) >> at >> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessor= Impl.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: >> >> :./../../..//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.ja= r:./../../..//lib/compress-lzf-0.8.4.jar:./../../..//lib/concurrentlinkedha= shmap-lru-1.3.jar:./../../..//lib/guava-13.0.1.jar:./../../..//lib/high-sca= le-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:./../../..//li= b/jline-1.0.jar:./../../..//lib/json-simple-1.1.jar:./../../..//lib/libthri= ft-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.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/ja= rs/ant-1.6.5.jar:./../../..//build/lib/jars/apache-rat-0.6.jar:./../../..//= build/lib/jars/apache-rat-core-0.6.jar:./../../..//build/lib/jars/apache-ra= t-tasks-0.6.jar:./../../..//build/lib/jars/asm-3.2.jar:./../../..//build/li= b/jars/avro-1.3.2.jar:./../../..//build/lib/jars/commons-beanutils-1.7.0.ja= r:./../../..//build/lib/jars/commons-beanutils-core-1.8.0.jar:./../../..//b= uild/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/com= mons-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/commons-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/core-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/jas= per-compiler-5.5.12.jar:./../../..//build/lib/jars/jasper-runtime-5.5.12.ja= r:./../../..//build/lib/jars/jets3t-0.7.1.jar:./../../..//build/lib/jars/je= tty-6.1.26.jar:./../../..//build/lib/jars/jetty-util-6.1.26.jar:./../../../= /build/lib/jars/jna-3.2.7.jar:./../../..//build/lib/jars/jopt-simple-3.2.ja= r:./../../..//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/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/apach= e-cassandra-1.2.0-SNAPSHOT.jar:./../../..//build/apache-cassandra-clientuti= l-1.2.0-SNAPSHOT.jar:./../../..//build/apache-cassandra-thrift-1.2.0-SNAPSH= OT.jar:/Users/mamartin/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-fixes.jar:./../../..//lib/commons-cli-1.1.j= ar:./../../..//lib/commons-codec-1.2.jar:./../../..//lib/commons-lang-2.6.j= ar:./../../..//lib/compress-lzf-0.8.4.jar:./../../..//lib/concurrentlinkedh= ashmap-lru-1.3.jar:./../../..//lib/guava-13.0.1.jar:./../../..//lib/high-sc= ale-lib-1.1.2.jar:./../../..//lib/jackson-core-asl-1.9.2.jar:./../../..//li= b/jackson-mapper-asl-1.9.2.jar:./../../..//lib/jamm-0.2.5.jar:./../../..//l= ib/jline-1.0.jar:./../../..//lib/json-simple-1.1.jar:./../../..//lib/libthr= ift-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-ap= i-2.5-20081211.jar:./../../..//lib/slf4j-api-1.7.2.jar:./../../..//lib/slf4= j-log4j12-1.7.2.jar:./../../..//lib/snakeyaml-1.6.jar:./../../..//lib/snapp= y-java-1.0.4.1.jar:./../../..//lib/snaptree-0.1.jar:./../../..//build/lib/j= ars/ant-1.6.5.jar:./../../..//build/lib/jars/apache-rat-0.6.jar:./../../../= /build/lib/jars/apache-rat-core-0.6.jar:./../../..//build/lib/jars/apache-r= at-tasks-0.6.jar:./../../..//build/lib/jars/asm-3.2.jar:./../../..//build/l= ib/jars/avro-1.3.2.jar:./../../..//build/lib/jars/commons-beanutils-1.7.0.j= ar:./../../..//build/lib/jars/commons-beanutils-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/co= mmons-digester-1.8.jar:./../../..//build/lib/jars/commons-el-1.0.jar:./../.= ./..//build/lib/jars/commons-httpclient-3.0.1.jar:./../../..//build/lib/jar= s/commons-lang-2.4.jar:./../../..//build/lib/jars/commons-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/core-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/ja= sper-compiler-5.5.12.jar:./../../..//build/lib/jars/jasper-runtime-5.5.12.j= ar:./../../..//build/lib/jars/jets3t-0.7.1.jar:./../../..//build/lib/jars/j= etty-6.1.26.jar:./../../..//build/lib/jars/jetty-util-6.1.26.jar:./../../..= //build/lib/jars/jna-3.2.7.jar:./../../..//build/lib/jars/jopt-simple-3.2.j= ar:./../../..//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/paraname= r-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.ja= r:./../../..//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/apac= he-cassandra-1.2.0-SNAPSHOT.jar:./../../..//build/apache-cassandra-clientut= il-1.2.0-SNAPSHOT.jar:./../../..//build/apache-cassandra-thrift-1.2.0-SNAPS= HOT.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= /pig/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> >> >> >> >> ________________________________________________________________________= _________________________________________________ >> >> Ce message et ses pieces jointes peuvent contenir des informations confi= dentielles ou privilegiees et ne doivent donc >> pas etre diffuses, exploites ou copies sans autorisation. Si vous avez r= ecu ce message par erreur, veuillez le signaler >> a l'expediteur et le detruire ainsi que les pieces jointes. Les messages= electroniques etant susceptibles d'alteration, >> France Telecom - Orange decline toute responsabilite si ce message a ete= altere, deforme ou falsifie. Merci. >> >> This message and its attachments may contain confidential or privileged = information that may be protected by law; >> they should not be distributed, used or copied without authorisation. >> If you have received this email in error, please notify the sender and d= elete this message and its attachments. >> As emails may be altered, France Telecom - Orange is not liable for mess= ages that have been modified, changed or falsified. >> Thank you. >> >> > > _________________________________________________________________________= ________________________________________________ > > Ce message et ses pieces jointes peuvent contenir des informations confid= entielles ou privilegiees et ne doivent donc > pas etre diffuses, exploites ou copies sans autorisation. Si vous avez re= cu ce message par erreur, veuillez le signaler > a l'expediteur et le detruire ainsi que les pieces jointes. Les messages = electroniques etant susceptibles d'alteration, > France Telecom - Orange decline toute responsabilite si ce message a ete = altere, deforme ou falsifie. Merci. > > This message and its attachments may contain confidential or privileged i= nformation that may be protected by law; > they should not be distributed, used or copied without authorisation. > If you have received this email in error, please notify the sender and de= lete this message and its attachments. > As emails may be altered, France Telecom - Orange is not liable for messa= ges that have been modified, changed or falsified. > Thank you. > > --001a11c261d84ea06804d9f00468 Content-Type: text/html; charset=ISO-8859-1 Content-Transfer-Encoding: quoted-printable
hi=A0cscetbon!!!

thanks for your reply ...

Yes, i use pig_cassandra, ad yes it,s like a shell script that loads li= braries from Cassandra
=A0(prefer cassandra -src ) dis= tro with folders build/lib/jar and otherts=A0paths of libs and s= et=A0
PIG_CLASSPATH and PIG_OPTS like you write. And like i told before = i chek that the libs are load=A0
=A0 and i try to incl= ude un grunt shell with require .

I cheked that the classes that is failin= g (=A0ja= va.lang.= NoClassDefFoundError) are in jars


  • Cassandrastorage =A0in=A0apache-cassandra-1.2.0.jar
  • StoreFuncInterf<= span style=3D"font-family:arial,sans-serif;font-size:13px">ace in pig.jar




i=B4ll =A0try your option ... it=B4s sound go= od !!!!=A0


i didn= =B4t hope that this issue (load data from cassandra in tuples pig ) take me= so time as it. =A0


First I try to develop and install = in local to scale it to EC2 where i have install hadoop, =A0cassandra ring = , etc...
Now i connect Cassandra with PIG =A0in a in a cludera C= D4 virtualmachine and Its works....well, ... , =A0I dont have the error = of load cassandraStorage
=A0but= i can`t read data from the table () i have no records from cassandra when = i load a =A0CF=A0

=A0i don,t want to use this environment and version of hadoop, etc..=


I am grateful for any help I c= an ge

=


Regards
















2013/4/8 <cscetbon= .ext@orange.com>
Are you using pig_cassandra ? its role is to add cassandra classes that Pig= needs to find classes like CassandraStorage. Here is my commandline it use= s :

exec /Library/Java/JavaVirtualMachines/jdk1.7.0_09.jdk/Contents/Home/bin/ja= va -Xmx1000m -Dudf.import.list=3Dorg.apache.cassandra.hadoop.pig -Dpig.log.= dir=3D/usr/local/bin/../Cellar/pig/0.11.0/bin/../logs -Dpig.log.file=3Dpig.= log -Dpig.home.dir=3D/usr/local/bin/../Cellar/pig/0.11.0/bin/.. -classpath = ':/Library/Java/JavaVirtualMachines/jdk1.7.0_09.jdk/Contents/Home/lib/t= ools.jar:::/usr/local/Cellar/cassandra/1.2.3/*:/usr/local/Cellar/pig/0.11.0= /pig-0.11.0.jar:/usr/local/bin/../Cellar/pig/0.11.0/bin/../pig-0.11.0.jar&#= 39; org.apache.pig.Main /Users/cyril/tmp/example-script.pig

FYI, there is the following line in pig_cassandra that allows us to not use= the whole prefixed name for CassandraStorage :

export PIG_OPTS=3D"$PIG_= OPTS -Dudf.import.list=3Dorg.apache.cassandra.hadoop.pig"


--=A0
Cyril SCETBON

On Apr 5, 2013, at 7:00 PM, Miguel Angel Martin junquera <= mianm= arjun.mailinglist@gmail.com> wrote:

expothanks for the reply=A0

please ....=

can you explain how do you config your =A0environtment.= ...????





Like you see, when I print classpath that export in pig_cassandr= a after call ... and I saw that class is in the jar

I still have this error and i tried with casandra-src and build =A0and pi= g 0.10 too.


ERROR 1070: Could not resolve Cassa= ndraStorage using imports: [, org.apache.pig.builtin., org.apache.pig.impl.= builtin.]

Failed to parse: Pig script failed to= parse:=A0
<line 1, column 48> pig script failed to validate: org.apache= .pig.backend.executionengine.ExecException: ERROR 1070: Could not resolve C= assandraStorage using imports: [, org.apache.pig.builtin., org.apache.pig.i= mpl.builtin.]
at org.apache.pig.pars= er.QueryParserDriver.parse(QueryParserDriver.java:191)
=



and also =A0wit= h the issue

grunt> rows =3D LOAD 'cassandra://Keyspa= ce1/Users' USING org.apache.cassandra.hadoop.pig.CassandraStorage()= AS (key, columns: bag {T: tuple(name, value)});
2013-04-05 18:16:45,118 [main] ERROR org.apache.pig.tools.grunt.Grunt = - ERROR 2998: Unhandled internal error. org/apache/pig/StoreFuncI= nterface

this class is in pig.jar that = load in PIG_CLASSPATH like that i can see in the trace log=A0
....


=A0PIG_CLASSPATH:=A0
::./../../..//lib/antlr-= 3.2.jar:./../../..//lib/avro-1.4.0-fixes.jar:./../../..//lib/avro-1.4.0-sou= rces-fixes.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.= jar:./../../..//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/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/jars/commons-beanutils-1.7.0.jar:./../../..//build/lib/ja= rs/commons-beanutils-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-con= figuration-1.6.jar:./../../..//build/lib/jars/commons-digester-1.8.jar:./..= /../..//build/lib/jars/commons-el-1.0.jar:./../../..//build/lib/jars/common= s-httpclient-3.0.1.jar:./../../..//build/lib/jars/commons-lang-2.4.jar:./..= /../..//build/lib/jars/commons-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/core-3.1.1.jar:./../../..//build/lib/jars/hadoop-cor= e-1.0.3.jar:./../../..//build/lib/jars/hsqldb-1.8.0.10.jar:./../../..//buil= d/lib/jars/jackson-core-asl-1.0.1.jar:./../../..//build/lib/jars/jackson-ma= pper-asl-1.0.1.jar:./../../..//build/lib/jars/jasper-compiler-5.5.12.jar:./= ../../..//build/lib/jars/jasper-runtime-5.5.12.jar:./../../..//build/lib/ja= rs/jets3t-0.7.1.jar:./../../..//build/lib/jars/jetty-6.1.26.jar:./../../../= /build/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/ja= rs/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/paran= amer-2.2.jar:./../../..//build/lib/jars/paranamer-ant-2.1.jar:./../../..//b= uild/lib/jars/paranamer-generator-2.1.jar:./../../..//build/lib/jars/pig-0.= 10.0.jar:./../../..//build/lib/jars/qdox-1.10.jar:./../../..//build/lib/jar= s/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-SNAPSHOT= .jar:./../../..//build/apache-cassandra-clientutil-1.2.0-SNAPSHOT.jar:./../= ../..//build/apache-cassandra-thrift-1.2.0-SNAPSHOT.jar:/Users/mamartin/Des= arrollo/pig-0.10.0/pig.jar


now in classpath i put =A0= pig-0.10.0 that i trying to testing with cassandra-1.2.0 and i deifne the P= IG_HOME in .bash_profile to this version.
=A0This is the PIG vers= ion that use =A0cassandra 1.2.0
but i have the same error....


= I also export =A0cassandra jars in the hadoop-env.sh.=A0And I hav= e this issues with and without hadoop .





2013/4/5 <cscetbon.ext@orange.com<= /a>>
It works= for me with cassandra 1.2.2 and Pig 0.11.0
--=A0
Cyril SCETBON

<= br>
I had the = same issue when trying to us Pig 0.11.x. I think the interface changed on t= he Pig side. I've stuck with using Pig 0.10.x on Cassandra (1.1.5). I&#= 39;m not sure about Cassandra 1.2, but I think it should be fine. If we nee= d a patch to get newer versions of Pig to work on Cassandra, how would we i= ncorporate the change? Create a new version of CassandraStorage or add swit= ches to the code? I'd be willing to contribute.

Bryan


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

Hi all:


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



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


My environmet config Is t= his:

  • mac OX lion
  • Cassandra 1.2.0= =A0
  • 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= =A0

2.- I`ve crea= te and insert data in columFamilys (Ex: account ) in =A0pygmalion keystore = =A0with casandra_cli =A0and it is ok in Cassandra I=B4m using =A0opscenter = to see data..

3.- I download casandr= a.1.2.0-src and I check adn the instructions in README file in the examples= /pig/ =A0folder. =A0I run script pig_cassandra =A0in local with ./pig_casan= dra -x local (i try too with hadoop and run ok)=A0

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


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

I saw this blog<= /div>

=
but dont works f= or me.

=

I try to load data wit= h:

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




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

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=A0register like

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


but i have the same error


I appreciate any help or any idea

Thanks in advance..

PD:

=A0logs 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/li= bexec
export JAVA_HOME=3D$(/usr/libexec/java_home)
export PATH=3D$PATH:$HADOOP_HOME/bin
export MAVEN_OPTS=3D&qu= ot;-Xmx1024M -XX:MaxPermSize=3D256M"
export PIG_HOME=3D/User= s/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.RandomP= artitioner


=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 S= tack Trace
---------------
ERROR 1070: Could not resolve CassandraStorage using imports: [, org.apache= .pig.builtin., org.apache.pig.impl.builtin.]

Faile= d to parse: Pig script failed to parse:=A0
<line 1, column 48&= gt; pig script failed to validate: org.apache.pig.backend.executionengine.E= xecException: 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.validat= eQuery(PigServer.java:1571)
at org.apache.pig.PigServ= er$Graph.registerQuery(PigServer.java:1544)
at org.apache.pig.PigServer.registerQuery(PigServer= .java:516)
at org.apache.pig.tools.g= runt.GruntParser.processPig(GruntParser.java:991)
at org.apache.pig.tools.pigscript.parser.PigS= criptParser.parse(PigScriptParser.java:412)
at org.apache.pig.tools.g= runt.GruntParser.parseStopOnError(GruntParser.java:194)
at org.apache.pig.tools.grunt.GruntPars= er.parseStopOnError(GruntParser.java:170)
at org.apache.pig.tools.g= runt.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.NativeMeth= odAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMeth= odAccessorImpl.java:39)
at sun.reflect.Delegating= MethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
<= span style=3D"white-space:pre-wrap"> at java.lang.reflect.Method.inv= oke(Method.java:597)
at org.apache.hadoop.util= .RunJar.main(RunJar.java:156)
Caused by:=A0
<line 1,= column 48> pig script failed to validate: org.apache.pig.backend.execut= ionengine.ExecException: ERROR 1070: Could not resolve CassandraStorage usi= ng imports: [, org.apache.pig.builtin., org.apache.pig.impl.builtin.]
at org.apache.pig.parser.= LogicalPlanBuilder.validateFuncSpec(LogicalPlanBuilder.java:1209)
at org.apache.pig.parser.Logi= calPlanBuilder.buildFuncSpec(LogicalPlanBuilder.java:1194)
at org.apache.pig.parser.= LogicalPlanGenerator.func_clause(LogicalPlanGenerator.java:4766)
= at org.apache.pig.parser.Logic= alPlanGenerator.load_clause(LogicalPlanGenerator.java:3183)
at org.apache.pig.parser.= LogicalPlanGenerator.op_clause(LogicalPlanGenerator.java:1315)
at org.apache.pig.parser.Logical= PlanGenerator.general_statement(LogicalPlanGenerator.java:799)
at org.apache.pig.parser.= LogicalPlanGenerator.statement(LogicalPlanGenerator.java:517)
at org.apache.pig.parser.LogicalP= lanGenerator.query(LogicalPlanGenerator.java:392)
at org.apache.pig.parser.= QueryParserDriver.parse(QueryParserDriver.java:184)
... 15 more
Caused by: org.apac= he.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.Pi= gContext.resolveClassName(PigContext.java:523)
at org.apache.pig.parser.LogicalPlanBuilder.vali= dateFuncSpec(LogicalPlanBuilder.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/StoreFun= cInterface
at java.l= ang.ClassLoader.defineClass1(Native Method)
at java.lang.ClassLoader.defineClassCond(ClassLoade= r.java:631)
at java.lang.ClassLoader.= defineClass(ClassLoader.java:615)
at java.security.SecureClassLoader.defineClass(SecureClassLoa= der.java:141)
at java.net.URLClassLoade= r.defineClass(URLClassLoader.java:283)
at java.net.URLClassLoader.access$000(URLClassLoader.jav= a:58)
at java.net.URLClassLoade= r$1.run(URLClassLoader.java:197)
at java.security.AccessController.doPrivileged(Native Method)<= /div>
at java.net.URLClassLoade= r.findClass(URLClassLoader.java:190)
at java.lang.ClassLoader.loadClass(ClassLoader.java:306)
at sun.misc.Launcher$AppC= lassLoader.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(Na= tive Method)
at java= .lang.Class.forName(Class.java:247)
at org.apache.pig.impl.PigContext.resolveClassName(PigConte= xt.java:505)
at org.apache.pig.parser.= LogicalPlanBuilder.validateFuncSpec(LogicalPlanBuilder.java:1206)
at org.apache.pig.parser.Logi= calPlanBuilder.buildFuncSpec(LogicalPlanBuilder.java:1194)
at org.apache.pig.parser.= LogicalPlanGenerator.func_clause(LogicalPlanGenerator.java:4766)
= at org.apache.pig.parser.Logic= alPlanGenerator.load_clause(LogicalPlanGenerator.java:3183)
at org.apache.pig.parser.= LogicalPlanGenerator.op_clause(LogicalPlanGenerator.java:1315)
at org.apache.pig.parser.Logical= PlanGenerator.general_statement(LogicalPlanGenerator.java:799)
at org.apache.pig.parser.= LogicalPlanGenerator.statement(LogicalPlanGenerator.java:517)
at org.apache.pig.parser.LogicalP= lanGenerator.query(LogicalPlanGenerator.java:392)
at org.apache.pig.parser.= QueryParserDriver.parse(QueryParserDriver.java:184)
at org.apache.pig.PigServer$Graph.validat= eQuery(PigServer.java:1571)
at org.apache.pig.PigServ= er$Graph.registerQuery(PigServer.java:1544)
at org.apache.pig.PigServer.registerQuery(PigServer= .java:516)
at org.apache.pig.tools.g= runt.GruntParser.processPig(GruntParser.java:991)
at org.apache.pig.tools.pigscript.parser.PigS= criptParser.parse(PigScriptParser.java:412)
at org.apache.pig.tools.g= runt.GruntParser.parseStopOnError(GruntParser.java:194)
at org.apache.pig.tools.grunt.GruntPars= er.parseStopOnError(GruntParser.java:170)
at org.apache.pig.tools.g= runt.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.NativeMeth= odAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMeth= odAccessorImpl.java:39)
at sun.reflect.Delegating= MethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
<= span style=3D"white-space:pre-wrap"> at java.lang.reflect.Method.inv= oke(Method.java:597)
at org.apache.hadoop.util= .RunJar.main(RunJar.java:156)
Caused by: java.lang.ClassNotFoundE= xception: org.apache.pig.StoreFuncInterface
at java.net.URLClassLoader$1.run(URLClassLoader.jav= a:202)
at java.security.AccessCo= ntroller.doPrivileged(Native Method)
at java.net.URLClassLoader.findClass(URLClassLoader.java:1= 90)
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: Unhand= led internal error. org/apache/pig/StoreFuncInterface

<= div>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(SecureClassLoa= der.java:141)
at java.net.URLClassLoade= r.defineClass(URLClassLoader.java:283)
at java.net.URLClassLoader.access$000(URLClassLoader.jav= a:58)
at java.net.URLClassLoade= r$1.run(URLClassLoader.java:197)
at java.security.AccessController.doPrivileged(Native Method)<= /div>
at java.net.URLClassLoade= r.findClass(URLClassLoader.java:190)
at java.lang.ClassLoader.loadClass(ClassLoader.java:306)
at sun.misc.Launcher$AppC= lassLoader.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(Na= tive Method)
at java= .lang.Class.forName(Class.java:247)
at org.apache.pig.impl.PigContext.resolveClassName(PigConte= xt.java:505)
at org.apache.pig.parser.= LogicalPlanBuilder.validateFuncSpec(LogicalPlanBuilder.java:1206)
at org.apache.pig.parser.Logi= calPlanBuilder.buildFuncSpec(LogicalPlanBuilder.java:1194)
at org.apache.pig.parser.= LogicalPlanGenerator.func_clause(LogicalPlanGenerator.java:4766)
= at org.apache.pig.parser.Logic= alPlanGenerator.load_clause(LogicalPlanGenerator.java:3183)
at org.apache.pig.parser.= LogicalPlanGenerator.op_clause(LogicalPlanGenerator.java:1315)
at org.apache.pig.parser.Logical= PlanGenerator.general_statement(LogicalPlanGenerator.java:799)
at org.apache.pig.parser.= LogicalPlanGenerator.statement(LogicalPlanGenerator.java:517)
at org.apache.pig.parser.LogicalP= lanGenerator.query(LogicalPlanGenerator.java:392)
at org.apache.pig.parser.= QueryParserDriver.parse(QueryParserDriver.java:184)
at org.apache.pig.PigServer$Graph.validat= eQuery(PigServer.java:1571)
at org.apache.pig.PigServ= er$Graph.registerQuery(PigServer.java:1544)
at org.apache.pig.PigServer.registerQuery(PigServer= .java:516)
at org.apache.pig.tools.g= runt.GruntParser.processPig(GruntParser.java:991)
at org.apache.pig.tools.pigscript.parser.PigS= criptParser.parse(PigScriptParser.java:412)
at org.apache.pig.tools.g= runt.GruntParser.parseStopOnError(GruntParser.java:194)
at org.apache.pig.tools.grunt.GruntPars= er.parseStopOnError(GruntParser.java:170)
at org.apache.pig.tools.g= runt.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.NativeMeth= odAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMeth= odAccessorImpl.java:39)
at sun.reflect.Delegating= MethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
<= span style=3D"white-space:pre-wrap"> at java.lang.reflect.Method.inv= oke(Method.java:597)
at org.apache.hadoop.util= .RunJar.main(RunJar.java:156)
Caused by: java.lang.ClassNotFoundE= xception: org.apache.pig.StoreFuncInterface
at java.net.URLClassLoader$1.run(URLClassLoader.jav= a:202)
at java.security.AccessCo= ntroller.doPrivileged(Native Method)
at java.net.URLClassLoader.findClass(URLClassLoader.java:1= 90)
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: Unhand= led internal error. org/apache/pig/StoreFuncInterface

<= /div>
I modified = the pig_cassandra, adding an echo to debug the classpath variables =A0and w= hen i run pig_cassandra =A0and it seem that the jar is in classpath .
This is the trac= e:


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

<= br>



./pig_cassandra -x= local
Using= /Users/mamartin/Desarrollo/pig-0.11.1/pig.jar.
=A0CLASSPATH:=A0<= /div>
:./../../..//lib/antlr-3.2.jar:./../../..//lib/avro-1.4.0-fixes.j= ar:./../../..//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.jar:./../../..//lib/compress-lzf-0.8.4.jar:./../../..//lib/concurrentl= inkedhashmap-lru-1.3.jar:./../../..//lib/guava-13.0.1.jar:./../../..//lib/h= igh-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/metric= s-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:./../../..//li= b/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/apache-rat-core-0.6.jar:./../../..//build/lib/jars/ap= ache-rat-tasks-0.6.jar:./../../..//build/lib/jars/asm-3.2.jar:./../../..//b= uild/lib/jars/avro-1.3.2.jar:./../../..//build/lib/jars/commons-beanutils-1= .7.0.jar:./../../..//build/lib/jars/commons-beanutils-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/j= ars/commons-digester-1.8.jar:./../../..//build/lib/jars/commons-el-1.0.jar:= ./../../..//build/lib/jars/commons-httpclient-3.0.1.jar:./../../..//build/l= ib/jars/commons-lang-2.4.jar:./../../..//build/lib/jars/commons-logging-1.1= .1.jar:./../../..//build/lib/jars/commons-math-2.1.jar:./../../..//build/li= b/jars/commons-net-1.4.1.jar:./../../..//build/lib/jars/core-3.1.1.jar:./..= /../..//build/lib/jars/hadoop-core-1.0.3.jar:./../../..//build/lib/jars/hsq= ldb-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/j= ars/jasper-compiler-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:./..= /../..//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/li= b/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/pa= ranamer-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:./../../..//buil= d/apache-cassandra-1.2.0-SNAPSHOT.jar:./../../..//build/apache-cassandra-cl= ientutil-1.2.0-SNAPSHOT.jar:./../../..//build/apache-cassandra-thrift-1.2.0= -SNAPSHOT.jar:/Users/mamartin/Desarrollo/pig-0.11.1/pig.jar
=A0PIG_CLASSPATH:=A0
::./../../..//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.jar:./../../..//lib/compress-lzf-0.8.4.jar:= ./../../..//lib/concurrentlinkedhashmap-lru-1.3.jar:./../../..//lib/guava-1= 3.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-simp= le-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.Fin= al.jar:./../../..//lib/servlet-api-2.5-20081211.jar:./../../..//lib/slf4j-a= pi-1.7.2.jar:./../../..//lib/slf4j-log4j12-1.7.2.jar:./../../..//lib/snakey= aml-1.6.jar:./../../..//lib/snappy-java-1.0.4.1.jar:./../../..//lib/snaptre= e-0.1.jar:./../../..//build/lib/jars/ant-1.6.5.jar:./../../..//build/lib/ja= rs/apache-rat-0.6.jar:./../../..//build/lib/jars/apache-rat-core-0.6.jar:./= ../../..//build/lib/jars/apache-rat-tasks-0.6.jar:./../../..//build/lib/jar= s/asm-3.2.jar:./../../..//build/lib/jars/avro-1.3.2.jar:./../../..//build/l= ib/jars/commons-beanutils-1.7.0.jar:./../../..//build/lib/jars/commons-bean= utils-core-1.8.0.jar:./../../..//build/lib/jars/commons-cli-1.2.jar:./../..= /..//build/lib/jars/commons-codec-1.4.jar:./../../..//build/lib/jars/common= s-collections-3.2.jar:./../../..//build/lib/jars/commons-configuration-1.6.= jar:./../../..//build/lib/jars/commons-digester-1.8.jar:./../../..//build/l= ib/jars/commons-el-1.0.jar:./../../..//build/lib/jars/commons-httpclient-3.= 0.1.jar:./../../..//build/lib/jars/commons-lang-2.4.jar:./../../..//build/l= ib/jars/commons-logging-1.1.1.jar:./../../..//build/lib/jars/commons-math-2= .1.jar:./../../..//build/lib/jars/commons-net-1.4.1.jar:./../../..//build/l= ib/jars/core-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/jack= son-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/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:./../../..//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.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/p= aranamer-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/xmlen= c-0.52.jar:./../../..//build/apache-cassandra-1.2.0-SNAPSHOT.jar:./../../..= //build/apache-cassandra-clientutil-1.2.0-SNAPSHOT.jar:./../../..//build/ap= ache-cassandra-thrift-1.2.0-SNAPSHOT.jar:/Users/mamartin/Desarrollo/pig-0.1= 1.1/pig.jar
2013-04-04 20:01:35,892 [main] INFO =A0org.apache.pig.Main - Apache Pi= g version 0.11.2-SNAPSHOT (rexported) compiled abr 03 2013, 17:18:03
<= div>2013-04-04 20:01:35,892 [main] INFO =A0org.apache.pig.Main - Logging er= ror messages to: /Users/mamartin/Desarrollo/cassandra/apache-cassandra-1.2.= 0-src/examples/pig/bin/pig_1365098495890.log
2013-04-04 20:01:35,912 [main] INFO =A0org.apache.pig.impl.util.Utils = - Default bootup file /Users/mamartin/.pigbootup not found
2013-0= 4-04 20:01:36,077 [main] INFO =A0org.apache.pig.backend.hadoop.executioneng= ine.HExecutionEngine - Connecting to hadoop file system at: file:///=
grunt>=A0


_____________________________________________________________________=
____________________________________________________

Ce message et ses pieces jointes peuvent contenir des informations confiden=
tielles ou privilegiees et ne doivent donc
pas etre diffuses, exploites ou copies sans autorisation. Si vous avez recu=
 ce message par erreur, veuillez le signaler
a l'expediteur et le detruire ainsi que les pieces jointes. Les message=
s electroniques etant susceptibles d'alteration,
France Telecom - Orange decline toute responsabilite si ce message a ete al=
tere, deforme ou falsifie. Merci.

This message and its attachments may contain confidential or privileged inf=
ormation that may be protected by law;
they should not be distributed, used or copied without authorisation.
If you have received this email in error, please notify the sender and dele=
te this message and its attachments.
As emails may be altered, France Telecom - Orange is not liable for message=
s that have been modified, changed or falsified.
Thank you.



_______________________________________________=
__________________________________________________________________________

Ce message et ses pieces jointes peuvent contenir des informations confiden=
tielles ou privilegiees et ne doivent donc
pas etre diffuses, exploites ou copies sans autorisation. Si vous avez recu=
 ce message par erreur, veuillez le signaler
a l'expediteur et le detruire ainsi que les pieces jointes. Les message=
s electroniques etant susceptibles d'alteration,
France Telecom - Orange decline toute responsabilite si ce message a ete al=
tere, deforme ou falsifie. Merci.

This message and its attachments may contain confidential or privileged inf=
ormation that may be protected by law;
they should not be distributed, used or copied without authorisation.
If you have received this email in error, please notify the sender and dele=
te this message and its attachments.
As emails may be altered, France Telecom - Orange is not liable for message=
s that have been modified, changed or falsified.
Thank you.

--001a11c261d84ea06804d9f00468--