Cassandra 1.0.9 と最新の Pig および Hadoop を使用して MapReduce タスクを実行しています。
Cassandra データベースから 2 つの列を抽出するために Pig でスクリプト化された単純なタスクです。
動作しているように見えますが、この問題が発生します。
java.lang.RuntimeException: org.apache.thrift.TApplicationException: org.apache.cassandra.hadoop.ColumnFamilyRecordReader$RowIterator.maybeInit(ColumnFamilyRecordReader.java:334) で get_range_slices を処理中に org.apache.cassandra.hadoop.ColumnFamilyRecordReader$ で内部エラーが発生しましたorg.apache.cassandra.hadoop.ColumnFamilyRecordReader$RowIterator.computeNext(ColumnFamilyRecordReader.java:222) で RowIterator.computeNext(ColumnFamilyRecordReader.java:348) 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.pig.backend.hadoop.executionengine の .getNext (不明なソース)。org.apache.hadoop.mapred.MapTask$NewTrackingRecordReader.nextKeyValue(MapTask.java:532) の mapReduceLayer.PigRecordReader.nextKeyValue(PigRecordReader.java:194) 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. org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1093) の doAs(Subject.java:396) org.apache.hadoop.mapred.Child.main(Child.java:249) の doAs(Subject.java:396) 原因: org .apache.thrift.TApplicationException: org.apache.thrift で get_range_slices を処理中に内部エラーが発生しました。org.apache.cassandra.thrift.Cassandra$Client.recv_get_range_slices(Cassandra.java:754) の TApplicationException.read(TApplicationException.java:108) org.apache.cassandra.thrift.Cassandra$Client.get_range_slices(Cassandra.java: 734) at org.apache.cassandra.hadoop.ColumnFamilyRecordReader$RowIterator.maybeInit(ColumnFamilyRecordReader.java:289) ... 17 詳細
それを回避する方法はありますか？リクエストに応じて、Pig スクリプトを表示できます。