Hello,
I am using Bulkoutputformat for Hadoop2Cassandra job using 0.20.2(cDh2u3) hadoop and 1.1.6 Cassnadra.
we have two rings Random (port 9160) & Byte order(9161) on same machine.
I am able load small amount of into Random order Cluster but not on Byte order cluster throwing below error.
Is there any issue changing ports ? or running on same machine ?
13/01/17 13:12:11 INFO mapred.JobClient: map 0% reduce 0%
13/01/17 13:12:23 INFO mapred.JobClient: Task Id : attempt_201301100944_4254_m_000000_0, Status : FAILED
java.io.IOException: Too many hosts failed: [/172.20.138.49, /172.20.138.48]
at org.apache.cassandra.hadoop.BulkRecordWriter.close(BulkRecordWriter.java:243)
at org.apache.cassandra.hadoop.BulkRecordWriter.close(BulkRecordWriter.java:208)
at org.apache.hadoop.mapred.MapTask$NewDirectOutputCollector.close(MapTask.java:540)
at org.apache.hadoop.mapred.MapTask.runNewMapper(MapTask.java:649)
at org.apache.hadoop.mapred.MapTask.run(MapTask.java:323)
at org.apache.hadoop.mapred.Child$4.run(Child.java:270)
at java.security.AccessController.doPrivileged(Native Method)
at javax.security.auth.Subject.doAs(Subject.java:396)
at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1157)
at org.apache.hadoop.mapred.Child.main(Child.java:264)
attempt_201301100944_4254_m_000000_0: Exception in thread "Streaming to /172.20.138.49:1" java.lang.RuntimeException: java.io.EOFException
thanks
chandu