我正在使用 Cassandra 1.0.9 和最新的 Pig 和 Hadoop 来执行 MapReduce 任务。
只是一个用 Pig 编写的简单任务，用于从 Cassandra 数据库中提取 2 列。
似乎工作，然后它遇到了这个问题。
java.lang.RuntimeException：org.apache.thrift.TApplicationException：在 org.apache.cassandra.hadoop.ColumnFamilyRecordReader$ 处处理 org.apache.cassandra.hadoop.ColumnFamilyRecordReader$RowIterator.maybeInit(ColumnFamilyRecordReader.java:334) 处的内部错误RowIterator.computeNext(ColumnFamilyRecordReader.java:348) at org.apache.cassandra.hadoop.ColumnFamilyRecordReader$RowIterator.computeNext(ColumnFamilyRecordReader.java:222) at com.google.common.collect.AbstractIterator.tryToComputeNext(AbstractIterator.java:140)在 com.google.common.collect.AbstractIterator.hasNext(AbstractIterator.java:135) 在 org.apache.cassandra.hadoop.ColumnFamilyRecordReader.nextKeyValue(ColumnFamilyRecordReader.java:178) 在 org.apache.cassandra.hadoop.pig.CassandraStorage org.apache.pig.backend.hadoop.executionengine 中的 .getNext（未知来源）。mapReduceLayer.PigRecordReader.nextKeyValue(PigRecordReader.java:194) at org.apache.hadoop.mapred.MapTask$NewTrackingRecordReader.nextKeyValue(MapTask.java:532) at org.apache.hadoop.mapreduce.MapContext.nextKeyValue(MapContext.java: 67) 在 org.apache.hadoop.mapreduce.Mapper.run(Mapper.java:143) 在 org.apache.hadoop.mapred.MapTask.runNewMapper(MapTask.java:764) 在 org.apache.hadoop.mapred.MapTask .run(MapTask.java:370) at org.apache.hadoop.mapred.Child$4.run(Child.java:255) 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:1093) at org.apache.hadoop.mapred.Child.main(Child.java:249) 原因：org .apache.thrift.TApplicationException：在 org.apache.thrift 处理 get_range_slices 的内部错误。TApplicationException.read(TApplicationException.java:108) at org.apache.cassandra.thrift.Cassandra$Client.recv_get_range_slices(Cassandra.java:754) at org.apache.cassandra.thrift.Cassandra$Client.get_range_slices(Cassandra.java: 734) 在 org.apache.cassandra.hadoop.ColumnFamilyRecordReader$RowIterator.maybeInit(ColumnFamilyRecordReader.java:289) ... 还有 17 个
有办法解决吗？我可以根据要求显示 Pig 脚本。