Did you get this sorted ? At a guess I would say there are no nodes listed in the Hadoop JobConf.
Cheers ----------------- Aaron Morton Freelance Cassandra Developer @aaronmorton http://www.thelastpickle.com On 23/08/2011, at 9:51 PM, Thamizh wrote: > Hi All, > > This is regarding multi-node cluster configuration doubt. > > I have configured 3 nodes of cluster using Cassandra-0.8.4 and getting error > when I ran Map/Reduce job which uploads records from HDFS to Cassandra. > > Here are my 3 nodes cluster config file (cassandra.yaml) for Cassandra: > > node01: > seeds: "node01,node02,node03" > auto_bootstrap: false > listen_address: 192.168.0.1 > rpc_address: 192.168.0.1 > > > node02: > > seeds: "node01,node02,node03" > auto_bootstrap: true > listen_address: 192.168.0.2 > rpc_address: 192.168.0.2 > > > node03: > seeds: "node01,node02,node03" > auto_bootstrap: true > listen_address: 192.168.0.3 > rpc_address: 192.168.0.3 > > When I ran M/R program, I am getting below error > 11/08/23 04:37:00 INFO mapred.JobClient: map 100% reduce 11% > 11/08/23 04:37:06 INFO mapred.JobClient: map 100% reduce 22% > 11/08/23 04:37:09 INFO mapred.JobClient: map 100% reduce 33% > 11/08/23 04:37:14 INFO mapred.JobClient: Task Id : > attempt_201104211044_0719_r_000000_0, Status : FAILED > java.lang.NullPointerException > at org.apache.cassandra.client.RingCache.getRange(RingCache.java:130) > at > org.apache.cassandra.hadoop.ColumnFamilyRecordWriter.write(ColumnFamilyRecordWriter.java:125) > at > org.apache.cassandra.hadoop.ColumnFamilyRecordWriter.write(ColumnFamilyRecordWriter.java:60) > at > org.apache.hadoop.mapreduce.TaskInputOutputContext.write(TaskInputOutputContext.java:80) > at CassTblUploader$TblUploadReducer.reduce(CassTblUploader.java:90) > at CassTblUploader$TblUploadReducer.reduce(CassTblUploader.java:1) > at org.apache.hadoop.mapreduce.Reducer.run(Reducer.java:174) > at org.apache.hadoop.mapred.ReduceTask.runNewReducer(ReduceTask.java:563) > at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:408) > at org.apache.hadoop.mapred.Child.main(Child.java:170) > > > Is anything wrong on my cassandra.yaml file? > > I followed http://wiki.apache.org/cassandra/MultinodeCluster for cluster > configuration. > > Regards, > Thamizhannal
