http://www.datastax.com/support-forums/topic/storing-to-cassandra-from-pig-using-cassandrastorage-not-working Software, Support, and Training for Apache Cassandra en-US Thu, 23 May 2013 11:41:28 +0000 http://bbpress.org/?v=1.0.3 q http://www.datastax.com/support-forums/search.php http://www.datastax.com/support-forums/topic/storing-to-cassandra-from-pig-using-cassandrastorage-not-working#post-7656 Fri, 23 Nov 2012 17:37:04 +0000 Piotr Kołaczkowski 7656@http://www.datastax.com/support-forums/ <p>Can you show me your dsetool ring? </p> http://www.datastax.com/support-forums/topic/storing-to-cassandra-from-pig-using-cassandrastorage-not-working#post-7651 Fri, 23 Nov 2012 07:25:35 +0000 abrahamjohnson 7651@http://www.datastax.com/support-forums/ <p>STORE B INTO 'cassandra://Keyspace/CF' USING CassandraStorage();</p> <p>B is in the format :<br /> (&lt;row_key&gt;,{(&lt;column_name1&gt;,&lt;value1&gt;),(&lt;column_name2&gt;,&lt;value2&gt;)})</p> <p>gives error :</p> <p>java.io.IOException: java.lang.RuntimeException: Invalid token information returned by describe_ring: {}<br /> at org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigGenericMapReduce$Reduce.runPipeline(PigGenericMapReduce.java:465)<br /> at org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigGenericMapReduce$Reduce.processOnePackageOutput(PigGenericMapReduce.java:428)<br /> at org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigGenericMapReduce$Reduce.reduce(PigGenericMapReduce.java:408)<br /> at org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigGenericMapReduce$Reduce.reduce(PigGenericMapReduce.java:262)<br /> at org.apache.hadoop.mapreduce.Reducer.run(Reducer.java:176)<br /> at org.apache.hadoop.mapred.ReduceTask.runNewReducer(ReduceTask.java:652)<br /> at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:420)<br /> at org.apache.hadoop.mapred.Child$4.run(Child.java:266)<br /> at java.security.AccessController.doPrivileged(Native Method)<br /> at javax.security.auth.Subject.doAs(Unknown Source)<br /> at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1093)<br /> at org.apache.hadoop.mapred.Child.main(Child.java:260)<br /> Caused by: java.lang.RuntimeException: Invalid token information returned by describe_ring: {}<br /> at org.apache.cassandra.client.RingCache.getRange(RingCache.java:122)<br /> at org.apache.cassandra.hadoop.ColumnFamilyRecordWriter.write(ColumnFamilyRecordWriter.java:130)<br /> at org.apache.cassandra.hadoop.ColumnFamilyRecordWriter.write(ColumnFamilyRecordWriter.java:60)<br /> at org.apache.cassandra.hadoop.pig.CassandraStorage.writeMutations(CassandraStorage.java:1001)<br /> at org.apache.cassandra.hadoop.pig.CassandraStorage.writeColumnsFromBag(CassandraStorage.java:994)<br /> at org.apache.cassandra.hadoop.pig.CassandraStorage.putNext(CassandraStorage.java:890)<br /> at org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigOutputFormat$PigRecordWriter.write(PigOutputFormat.java:139)<br /> at org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigOutputFormat$PigRecordWriter.write(PigOutputFormat.java:98)<br /> at org.apache.hadoop.mapred.ReduceTask$NewTrackingRecordWriter.write(ReduceTask.java:590)<br /> at org.apache.hadoop.mapreduce.TaskInputOutputContext.write(TaskInputOutputContext.java:80)<br /> at org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigGenericMapReduce$Reduce.runPipeline(PigGenericMapReduce.java:463)<br /> ... 11 more </p>