http://www.datastax.com/support-forums/topic/bulkoutput-byte-order Software, Support, and Training for Apache Cassandra en-US Wed, 22 May 2013 05:36:09 +0000 http://bbpress.org/?v=1.0.3 q http://www.datastax.com/support-forums/search.php http://www.datastax.com/support-forums/topic/bulkoutput-byte-order#post-8503 Fri, 18 Jan 2013 17:02:06 +0000 chandu 8503@http://www.datastax.com/support-forums/ <p>Hello,</p> <p>I am using Bulkoutputformat for Hadoop2Cassandra job using 0.20.2(cDh2u3) hadoop and 1.1.6 Cassnadra.<br /> we have two rings Random (port 9160) &amp; Byte order(9161) on same machine.<br /> I am able load small amount of into Random order Cluster but not on Byte order cluster throwing below error.</p> <p>Is there any issue changing ports ? or running on same machine ?</p> <p>13/01/17 13:12:11 INFO mapred.JobClient: map 0% reduce 0%<br /> 13/01/17 13:12:23 INFO mapred.JobClient: Task Id : attempt_201301100944_4254_m_000000_0, Status : FAILED<br /> java.io.IOException: Too many hosts failed: [/172.20.138.49, /172.20.138.48]<br /> at org.apache.cassandra.hadoop.BulkRecordWriter.close(BulkRecordWriter.java:243)<br /> at org.apache.cassandra.hadoop.BulkRecordWriter.close(BulkRecordWriter.java:208)<br /> at org.apache.hadoop.mapred.MapTask$NewDirectOutputCollector.close(MapTask.java:540)<br /> at org.apache.hadoop.mapred.MapTask.runNewMapper(MapTask.java:649)<br /> at org.apache.hadoop.mapred.MapTask.run(MapTask.java:323)<br /> at org.apache.hadoop.mapred.Child$4.run(Child.java:270)<br /> at java.security.AccessController.doPrivileged(Native Method)<br /> at javax.security.auth.Subject.doAs(Subject.java:396)<br /> at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1157)<br /> at org.apache.hadoop.mapred.Child.main(Child.java:264)</p> <p>attempt_201301100944_4254_m_000000_0: Exception in thread "Streaming to /172.20.138.49:1" java.lang.RuntimeException: java.io.EOFException</p> <p>thanks<br /> chandu </p>