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 57FFB1DCE for ; Wed, 20 Apr 2011 09:55:06 +0000 (UTC) Received: (qmail 45178 invoked by uid 500); 20 Apr 2011 09:55:04 -0000 Delivered-To: apmail-cassandra-user-archive@cassandra.apache.org Received: (qmail 45150 invoked by uid 500); 20 Apr 2011 09:55:04 -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 45140 invoked by uid 99); 20 Apr 2011 09:55:04 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 20 Apr 2011 09:55:04 +0000 X-ASF-Spam-Status: No, hits=3.7 required=5.0 tests=FREEMAIL_ENVFROM_END_DIGIT,FREEMAIL_FROM,HTML_MESSAGE,RCVD_IN_DNSWL_LOW,RFC_ABUSE_POST,SPF_PASS,T_TO_NO_BRKTS_FREEMAIL X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of peterob333@gmail.com designates 209.85.215.172 as permitted sender) Received: from [209.85.215.172] (HELO mail-ey0-f172.google.com) (209.85.215.172) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 20 Apr 2011 09:54:56 +0000 Received: by eye13 with SMTP id 13so202689eye.31 for ; Wed, 20 Apr 2011 02:54:36 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=gamma; h=domainkey-signature:mime-version:in-reply-to:references:date :message-id:subject:from:to:content-type; bh=h8cTLtL1M7LVeQ7G877kNwwwzl9iwNCyhOtiX+o5yV4=; b=PVhA1eDYbyr4r0tisxlq+inwFQxvDx3d98NBgdz3hAUqsdksvQH9C274zbXRfsbUcQ vOhfJKjzrs3+Dvn/NtgLRn5UnmQUUCGJAIgaZcmFGUw/jw8OU9T60aBHnNwZDsS0c46k eQZAQOn52IEnOwXcEib+3d56L4+fPgvNPcrso= DomainKey-Signature: a=rsa-sha1; c=nofws; d=gmail.com; s=gamma; h=mime-version:in-reply-to:references:date:message-id:subject:from:to :content-type; b=lLVmA31gEDQ7xYN01kFQg3oZHli7OQQhiMRTrh56Tp1Vzukg7CqvqBWR44ps+YdEtX GIz+ImVrxqIEjlaBONiWWTqwRnjldADfYpiOn3gmW6JHjidKQIEbSjImGikDR1TUGLNn 7pU8SS5Qtum/DZXaYkqxF2b0AdUIfB8PIZcxQ= MIME-Version: 1.0 Received: by 10.14.20.1 with SMTP id o1mr2625884eeo.63.1303293274763; Wed, 20 Apr 2011 02:54:34 -0700 (PDT) Received: by 10.14.37.139 with HTTP; Wed, 20 Apr 2011 02:54:34 -0700 (PDT) In-Reply-To: References: <5FAFCB6230A1754CBC58296E62D8D5E602FBDD7217@pa-ex-01.YOJOE.local> Date: Wed, 20 Apr 2011 11:54:34 +0200 Message-ID: Subject: Re: pig + hadoop From: pob To: user@cassandra.apache.org Content-Type: multipart/alternative; boundary=0016e6d62579ae302904a1569cfb X-Virus-Checked: Checked by ClamAV on apache.org --0016e6d62579ae302904a1569cfb Content-Type: text/plain; charset=ISO-8859-1 Hi, everything works fine with cassandra 0.7.5, but when I tried with 0.7.3 another errors showed up, but task finished with success whats strange..... 2011-04-20 11:45:40,674 INFO org.apache.hadoop.mapred.TaskInProgress: Error from attempt_201104201139_0004_m_000000_3: Error: java.lang.ClassNotF oundException: org.apache.thrift.TException 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:307) at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) at java.lang.ClassLoader.loadClass(ClassLoader.java:248) at java.lang.Class.forName0(Native Method) at java.lang.Class.forName(Class.java:247) at org.apache.pig.impl.PigContext.resolveClassName(PigContext.java:426) at org.apache.pig.impl.PigContext.instantiateFuncFromSpec(PigContext.java:456) at org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigInputFormat.getLoadFunc(PigInputFormat.java:153) at org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigInputFormat.createRecordReader(PigInputFormat.java:105) at org.apache.hadoop.mapred.MapTask.runNewMapper(MapTask.java:588) at org.apache.hadoop.mapred.MapTask.run(MapTask.java:305) at org.apache.hadoop.mapred.Child.main(Child.java:170) 2011-04-20 11:45:43,629 INFO org.apache.hadoop.mapred.TaskInProgress: Error from attempt_201104201139_0004_m_000001_3: org.apache.pig.backend.exe cutionengine.ExecException: ERROR 2044: The type null cannot be collected as a Key type at org.apache.pig.backend.hadoop.HDataType.getWritableComparableTypes(HDataType.java:143) at org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigMapReduce$Map.collect(PigMapReduce.java:105) at org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigMapBase.runPipeline(PigMapBase.java:238) at org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigMapBase.map(PigMapBase.java:231) at org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigMapBase.map(PigMapBase.java:53) at org.apache.hadoop.mapreduce.Mapper.run(Mapper.java:144) at org.apache.hadoop.mapred.MapTask.runNewMapper(MapTask.java:621) at org.apache.hadoop.mapred.MapTask.run(MapTask.java:305) at org.apache.hadoop.mapred.Child.main(Child.java:170) 2011-04-20 11:42:49,498 INFO org.apache.hadoop.mapred.TaskInProgress: Error from attempt_201104201139_0001_m_000000_1: Error: java.lang.ClassNotF oundException: org.apache.commons.lang.ArrayUtils 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:307) at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301) at java.lang.ClassLoader.loadClass(ClassLoader.java:248) at org.apache.cassandra.utils.ByteBufferUtil.(ByteBufferUtil.java:75) at org.apache.cassandra.hadoop.pig.CassandraStorage.(Unknown Source) at java.lang.Class.forName0(Native Method) at java.lang.Class.forName(Class.java:247) at org.apache.pig.impl.PigContext.resolveClassName(PigContext.java:426) at org.apache.pig.impl.PigContext.instantiateFuncFromSpec(PigContext.java:456) at org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigInputFormat.getLoadFunc(PigInputFormat.java:153) at org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigInputFormat.createRecordReader(PigInputFormat.java:105) at org.apache.hadoop.mapred.MapTask.runNewMapper(MapTask.java:588) at org.apache.hadoop.mapred.MapTask.run(MapTask.java:305) at org.apache.hadoop.mapred.Child.main(Child.java:170) 2011/4/20 Jeremy Hanna > Just as an example: > > > cassandra.thrift.address > 10.12.34.56 > > > cassandra.thrift.port > 9160 > > > cassandra.partitioner.class > org.apache.cassandra.dht.RandomPartitioner > > > > On Apr 19, 2011, at 10:28 PM, Jeremy Hanna wrote: > > > oh yeah - that's what's going on. what I do is on the machine that I run > the pig script from, I set the PIG_CONF variable to my HADOOP_HOME/conf > directory and in my mapred-site.xml file found there, I set the three > variables. > > > > I don't use environment variables when I run against a cluster. > > > > On Apr 19, 2011, at 9:54 PM, Jeffrey Wang wrote: > > > >> Did you set PIG_RPC_PORT in your hadoop-env.sh? I was seeing this error > for a while before I added that. > >> > >> -Jeffrey > >> > >> From: pob [mailto:peterob333@gmail.com] > >> Sent: Tuesday, April 19, 2011 6:42 PM > >> To: user@cassandra.apache.org > >> Subject: Re: pig + hadoop > >> > >> Hey Aaron, > >> > >> I read it, and all of 3 env variables was exported. The results are > same. > >> > >> Best, > >> P > >> > >> 2011/4/20 aaron morton > >> Am guessing but here goes. Looks like the cassandra RPC port is not set, > did you follow these steps in contrib/pig/README.txt > >> > >> Finally, set the following as environment variables (uppercase, > >> underscored), or as Hadoop configuration variables (lowercase, dotted): > >> * PIG_RPC_PORT or cassandra.thrift.port : the port thrift is listening > on > >> * PIG_INITIAL_ADDRESS or cassandra.thrift.address : initial address to > connect to > >> * PIG_PARTITIONER or cassandra.partitioner.class : cluster partitioner > >> > >> Hope that helps. > >> Aaron > >> > >> > >> On 20 Apr 2011, at 11:28, pob wrote: > >> > >> > >> Hello, > >> > >> I did cluster configuration by > http://wiki.apache.org/cassandra/HadoopSupport. When I run pig > example-script.pig > >> -x local, everything is fine and i get correct results. > >> > >> Problem is occurring with -x mapreduce > >> > >> Im getting those errors :> > >> > >> > >> 2011-04-20 01:24:21,791 [main] ERROR > org.apache.pig.tools.pigstats.PigStats - ERROR: > java.lang.NumberFormatException: null > >> 2011-04-20 01:24:21,792 [main] ERROR > org.apache.pig.tools.pigstats.PigStatsUtil - 1 map reduce job(s) failed! > >> 2011-04-20 01:24:21,793 [main] INFO > org.apache.pig.tools.pigstats.PigStats - Script Statistics: > >> > >> Input(s): > >> Failed to read data from "cassandra://Keyspace1/Standard1" > >> > >> Output(s): > >> Failed to produce result in > "hdfs://ip:54310/tmp/temp-1383865669/tmp-1895601791" > >> > >> Counters: > >> Total records written : 0 > >> Total bytes written : 0 > >> Spillable Memory Manager spill count : 0 > >> Total bags proactively spilled: 0 > >> Total records proactively spilled: 0 > >> > >> Job DAG: > >> job_201104200056_0005 -> null, > >> null -> null, > >> null > >> > >> > >> 2011-04-20 01:24:21,793 [main] INFO > org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MapReduceLauncher > - Failed! > >> 2011-04-20 01:24:21,803 [main] ERROR org.apache.pig.tools.grunt.Grunt - > ERROR 1066: Unable to open iterator for alias topnames. Backend error : > java.lang.NumberFormatException: null > >> > >> > >> > >> ==== > >> thats from jobtasks web management - error from task directly: > >> > >> java.lang.RuntimeException: java.lang.NumberFormatException: null > >> at > org.apache.cassandra.hadoop.ColumnFamilyRecordReader.initialize(ColumnFamilyRecordReader.java:123) > >> at > org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigRecordReader.initialize(PigRecordReader.java:176) > >> at > org.apache.hadoop.mapred.MapTask$NewTrackingRecordReader.initialize(MapTask.java:418) > >> at org.apache.hadoop.mapred.MapTask.runNewMapper(MapTask.java:620) > >> at org.apache.hadoop.mapred.MapTask.run(MapTask.java:305) > >> at org.apache.hadoop.mapred.Child.main(Child.java:170) > >> Caused by: java.lang.NumberFormatException: null > >> at java.lang.Integer.parseInt(Integer.java:417) > >> at java.lang.Integer.parseInt(Integer.java:499) > >> at > org.apache.cassandra.hadoop.ConfigHelper.getRpcPort(ConfigHelper.java:233) > >> at > org.apache.cassandra.hadoop.ColumnFamilyRecordReader.initialize(ColumnFamilyRecordReader.java:105) > >> ... 5 more > >> > >> > >> > >> Any suggestions where should be problem? > >> > >> Thanks, > >> > >> > >> > > > > --0016e6d62579ae302904a1569cfb Content-Type: text/html; charset=ISO-8859-1 Content-Transfer-Encoding: quoted-printable Hi,

everything works fine with cassandra 0.7.5, but when= I tried with 0.7.3 another errors showed up, but task finished with succes= s whats strange.....


2011-04-2= 0 11:45:40,674 INFO org.apache.hadoop.mapred.TaskInProgress: Error from att= empt_201104201139_0004_m_000000_3: Error: java.lang.ClassNotF
oundException: org.apache.thrift.TException
=A0=A0 =A0 =A0 = =A0at java.net.URLClassLoader$1.run(URLClassLoader.java:202)
=A0= =A0 =A0 =A0 =A0at java.security.AccessController.doPrivileged(Native Method= )
=A0=A0 =A0 =A0 =A0at java.net.URLClassLoader.findClass(URLClass= Loader.java:190)
=A0=A0 =A0 =A0 =A0at java.lang.ClassLoader.loadClass(ClassLoader.java:= 307)
=A0=A0 =A0 =A0 =A0at sun.misc.Launcher$AppClassLoader.loadCl= ass(Launcher.java:301)
=A0=A0 =A0 =A0 =A0at java.lang.ClassLoader= .loadClass(ClassLoader.java:248)
=A0=A0 =A0 =A0 =A0at java.lang.Class.forName0(Native Method)
=A0=A0 =A0 =A0 =A0at java.lang.Class.forName(Class.java:247)
=A0= =A0 =A0 =A0 =A0at org.apache.pig.impl.PigContext.resolveClassName(PigContex= t.java:426)
=A0=A0 =A0 =A0 =A0at org.apache.pig.impl.PigContext.i= nstantiateFuncFromSpec(PigContext.java:456)
=A0=A0 =A0 =A0 =A0at org.apache.pig.backend.hadoop.executionengine.map= ReduceLayer.PigInputFormat.getLoadFunc(PigInputFormat.java:153)
= =A0=A0 =A0 =A0 =A0at org.apache.pig.backend.hadoop.executionengine.mapReduc= eLayer.PigInputFormat.createRecordReader(PigInputFormat.java:105)
=A0=A0 =A0 =A0 =A0at org.apache.hadoop.mapred.MapTask.runNewMapper(Map= Task.java:588)
=A0=A0 =A0 =A0 =A0at org.apache.hadoop.mapred.MapT= ask.run(MapTask.java:305)
=A0=A0 =A0 =A0 =A0at org.apache.hadoop.= mapred.Child.main(Child.java:170)



2011-04-20 11:= 45:43,629 INFO org.apache.hadoop.mapred.TaskInProgress: Error from attempt_= 201104201139_0004_m_000001_3: org.apache.pig.backend.exe
cutionen= gine.ExecException: ERROR 2044: The type null cannot be collected as a Key = type
=A0=A0 =A0 =A0 =A0at org.apache.pig.backend.hadoop.HDataType.getWritab= leComparableTypes(HDataType.java:143)
=A0=A0 =A0 =A0 =A0at org.ap= ache.pig.backend.hadoop.executionengine.mapReduceLayer.PigMapReduce$Map.col= lect(PigMapReduce.java:105)
=A0=A0 =A0 =A0 =A0at org.apache.pig.backend.hadoop.executionengine.map= ReduceLayer.PigMapBase.runPipeline(PigMapBase.java:238)
=A0=A0 = =A0 =A0 =A0at org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.= PigMapBase.map(PigMapBase.java:231)
=A0=A0 =A0 =A0 =A0at org.apache.pig.backend.hadoop.executionengine.map= ReduceLayer.PigMapBase.map(PigMapBase.java:53)
=A0=A0 =A0 =A0 =A0= at org.apache.hadoop.mapreduce.Mapper.run(Mapper.java:144)
=A0=A0= =A0 =A0 =A0at org.apache.hadoop.mapred.MapTask.runNewMapper(MapTask.java:6= 21)
=A0=A0 =A0 =A0 =A0at org.apache.hadoop.mapred.MapTask.run(MapTask.java= :305)
=A0=A0 =A0 =A0 =A0at org.apache.hadoop.mapred.Child.main(Ch= ild.java:170)


2011-04-20= 11:42:49,498 INFO org.apache.hadoop.mapred.TaskInProgress: Error from atte= mpt_201104201139_0001_m_000000_1: Error: java.lang.ClassNotF
oundException: org.apache.commons.lang.ArrayUtils
=A0=A0 =A0= =A0 =A0at java.net.URLClassLoader$1.run(URLClassLoader.java:202)
=A0=A0 =A0 =A0 =A0at java.security.AccessController.doPrivileged(Native Me= thod)
=A0=A0 =A0 =A0 =A0at java.net.URLClassLoader.findClass(URLClassLoader.java:= 190)
=A0=A0 =A0 =A0 =A0at java.lang.ClassLoader.loadClass(ClassLo= ader.java:307)
=A0=A0 =A0 =A0 =A0at sun.misc.Launcher$AppClassLoa= der.loadClass(Launcher.java:301)
=A0=A0 =A0 =A0 =A0at java.lang.ClassLoader.loadClass(ClassLoader.java:= 248)
=A0=A0 =A0 =A0 =A0at org.apache.cassandra.utils.ByteBufferUt= il.<clinit>(ByteBufferUtil.java:75)
=A0=A0 =A0 =A0 =A0at or= g.apache.cassandra.hadoop.pig.CassandraStorage.<clinit>(Unknown Sourc= e)
=A0=A0 =A0 =A0 =A0at java.lang.Class.forName0(Native Method)
=A0=A0 =A0 =A0 =A0at java.lang.Class.forName(Class.java:247)
=A0= =A0 =A0 =A0 =A0at org.apache.pig.impl.PigContext.resolveClassName(PigContex= t.java:426)
=A0=A0 =A0 =A0 =A0at org.apache.pig.impl.PigContext.i= nstantiateFuncFromSpec(PigContext.java:456)
=A0=A0 =A0 =A0 =A0at org.apache.pig.backend.hadoop.executionengine.map= ReduceLayer.PigInputFormat.getLoadFunc(PigInputFormat.java:153)
= =A0=A0 =A0 =A0 =A0at org.apache.pig.backend.hadoop.executionengine.mapReduc= eLayer.PigInputFormat.createRecordReader(PigInputFormat.java:105)
=A0=A0 =A0 =A0 =A0at org.apache.hadoop.mapred.MapTask.runNewMapper(Map= Task.java:588)
=A0=A0 =A0 =A0 =A0at org.apache.hadoop.mapred.MapT= ask.run(MapTask.java:305)
=A0=A0 =A0 =A0 =A0at org.apache.hadoop.= mapred.Child.main(Child.java:170)





=
2011/4/20 Jeremy Hanna <jeremy.hanna1234@gmail.com&g= t;
Just as an example:

=A0<property>
=A0 =A0<name>cassandra.thrift.address</name>
=A0 =A0<value>10.12.34.56</value>
=A0</property>
=A0<property>
=A0 =A0<name>cassandra.thrift.port</name>
=A0 =A0<value>9160</value>
=A0</property>
=A0<property>
=A0 =A0<name>cassandra.partitioner.class</name>
=A0 =A0<value>org.apache.cassandra.dht.RandomPartitioner</value&g= t;
=A0</property>


On Apr 19, 2011, at 10:28 PM, Jeremy Hanna wrote:

> oh yeah - that's what's going on. =A0what I do is on the machi= ne that I run the pig script from, I set the PIG_CONF variable to my HADOOP= _HOME/conf directory and in my mapred-site.xml file found there, I set the = three variables.
>
> I don't use environment variables when I run against a cluster. >
> On Apr 19, 2011, at 9:54 PM, Jeffrey Wang wrote:
>
>> Did you set PIG_RPC_PORT in your hadoop-env.sh? I was seeing this = error for a while before I added that.
>>
>> -Jeffrey
>>
>> From: pob [mailto:peterob3= 33@gmail.com]
>> Sent: Tuesday, April 19, 2011 6:42 PM
>> To: user@cassandra.ap= ache.org
>> Subject: Re: pig + hadoop
>>
>> Hey Aaron,
>>
>> I read it, and all of 3 env variables was exported. The results ar= e same.
>>
>> Best,
>> P
>>
>> 2011/4/20 aaron morton <aaron@thelastpickle.com>
>> Am guessing but here goes. Looks like the cassandra RPC port is no= t set, did you follow these steps in contrib/pig/README.txt
>>
>> Finally, set the following as environment variables (uppercase, >> underscored), or as Hadoop configuration variables (lowercase, dot= ted):
>> * PIG_RPC_PORT or cassandra.thrift.port : the port thrift is liste= ning on
>> * PIG_INITIAL_ADDRESS or cassandra.thrift.address : initial addres= s to connect to
>> * PIG_PARTITIONER or cassandra.partitioner.class : cluster partiti= oner
>>
>> Hope that helps.
>> Aaron
>>
>>
>> On 20 Apr 2011, at 11:28, pob wrote:
>>
>>
>> Hello,
>>
>> I did cluster configuration by http://wiki.apache.org/cassandra/= HadoopSupport. When I run pig example-script.pig
>> -x local, everything is fine and i get correct results.
>>
>> Problem is occurring with -x mapreduce
>>
>> Im getting those errors :>
>>
>>
>> 2011-04-20 01:24:21,791 [main] ERROR org.apache.pig.tools.pigstats= .PigStats - ERROR: java.lang.NumberFormatException: null
>> 2011-04-20 01:24:21,792 [main] ERROR org.apache.pig.tools.pigstats= .PigStatsUtil - 1 map reduce job(s) failed!
>> 2011-04-20 01:24:21,793 [main] INFO =A0org.apache.pig.tools.pigsta= ts.PigStats - Script Statistics:
>>
>> Input(s):
>> Failed to read data from "cassandra://Keyspace1/Standard1&quo= t;
>>
>> Output(s):
>> Failed to produce result in "hdfs://ip:54310/tmp/temp-1383865= 669/tmp-1895601791"
>>
>> Counters:
>> Total records written : 0
>> Total bytes written : 0
>> Spillable Memory Manager spill count : 0
>> Total bags proactively spilled: 0
>> Total records proactively spilled: 0
>>
>> Job DAG:
>> job_201104200056_0005 =A0 -> =A0 =A0 =A0null,
>> null =A0 =A0-> =A0 =A0 =A0null,
>> null
>>
>>
>> 2011-04-20 01:24:21,793 [main] INFO =A0org.apache.pig.backend.hado= op.executionengine.mapReduceLayer.MapReduceLauncher - Failed!
>> 2011-04-20 01:24:21,803 [main] ERROR org.apache.pig.tools.grunt.Gr= unt - ERROR 1066: Unable to open iterator for alias topnames. Backend error= : java.lang.NumberFormatException: null
>>
>>
>>
>> =3D=3D=3D=3D
>> thats from jobtasks web management - error =A0from task directly:<= br> >>
>> java.lang.RuntimeException: java.lang.NumberFormatException: null<= br> >> at org.apache.cassandra.hadoop.ColumnFamilyRecordReader.initialize= (ColumnFamilyRecordReader.java:123)
>> at org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.Pi= gRecordReader.initialize(PigRecordReader.java:176)
>> at org.apache.hadoop.mapred.MapTask$NewTrackingRecordReader.initia= lize(MapTask.java:418)
>> at org.apache.hadoop.mapred.MapTask.runNewMapper(MapTask.java:620)=
>> at org.apache.hadoop.mapred.MapTask.run(MapTask.java:305)
>> at org.apache.hadoop.mapred.Child.main(Child.java:170)
>> Caused by: java.lang.NumberFormatException: null
>> at java.lang.Integer.parseInt(Integer.java:417)
>> at java.lang.Integer.parseInt(Integer.java:499)
>> at org.apache.cassandra.hadoop.ConfigHelper.getRpcPort(ConfigHelpe= r.java:233)
>> at org.apache.cassandra.hadoop.ColumnFamilyRecordReader.initialize= (ColumnFamilyRecordReader.java:105)
>> ... 5 more
>>
>>
>>
>> Any suggestions where should be problem?
>>
>> Thanks,
>>
>>
>>
>


--0016e6d62579ae302904a1569cfb--