You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@cassandra.apache.org by Gabriel Ki <ga...@gmail.com> on 2011/10/20 03:17:25 UTC
No local connection available in map reduce job
Hi,
Cassandra 1.0. I am getting the following exception from a simple map
reduce job. It seems like the local mapper is working.
I tried many combinations of hostname, localhost, ip in /etc/hosts vs
listen_address. Didn't seem to resolve this.
Any inputs will be appreciated.
Thanks,
-gabe
WARN [Thread-11] 2011-10-19 17:45:10,511 LocalJobRunner.java (line 256)
job_local_0001
java.lang.RuntimeException: java.lang.UnsupportedOperationException: no
local connection available
at
org.apache.cassandra.hadoop.ColumnFamilyRecordReader.initialize(ColumnFamilyRecordReader.java:132)
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.LocalJobRunner$Job.run(LocalJobRunner.java:177)
Caused by: java.lang.UnsupportedOperationException: no local connection
available
at
org.apache.cassandra.hadoop.ColumnFamilyRecordReader.getLocation(ColumnFamilyRecordReader.java:176)
at
org.apache.cassandra.hadoop.ColumnFamilyRecordReader.initialize(ColumnFamilyRecordReader.java:113)
... 4 more
INFO [main] 2011-10-19 17:45:10,920 JobClient.java (line 1288) map 100%
reduce 0%