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%