cassandra-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Gabriel Ki <gab...@gmail.com>
Subject No local connection available in map reduce job
Date Thu, 20 Oct 2011 01:17:25 GMT
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%

Mime
View raw message