hadoop pig cassandra get\u range\u slices错误

pzfprimi  于 2021-06-21  发布在  Pig
关注(0)|答案(0)|浏览(250)

我使用cassandra1.0.9和最新的pig和hadoop来执行mapreduce任务。
只是一个简单的任务,用pig脚本从cassandra数据库中提取2列。
似乎工作,然后它遇到了这个问题。
java.lang.runtimeexception:org.apache.thrift.tapplicationexception:org.apache.cassandra.hadoop.columnfamilyrecordreader$roweiterator.maybeinit(columnfamilyrecordreader)中处理get\u range\u切片时出现内部错误。java:334)在org.apache.cassandra.hadoop.columnfamilyrecordreader$roweiterator.computenext(columnfamilyrecordreader。java:348)在org.apache.cassandra.hadoop.columnfamilyrecordreader$行迭代器.computenext(columnfamilyrecordreader。java:222)在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.mapreducelayer.pigrecordreader.nextkeyvalue(pigrecordreader)的org.apache.cassandra.hadoop.pig.cassandrastorage.getnext(未知源代码)。java:194)在org.apache.hadoop.mapred.maptask$newtrackingrecordreader.nextkeyvalue(maptask。java:532)在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)在org.apache.hadoop.mapred.child$4.run(child。java:255)位于javax.security.auth.subject.doas(subject)的java.security.accesscontroller.doprivileged(本机方法)。java:396)在org.apache.hadoop.security.usergroupinformation.doas(usergroupinformation。java:1093)在org.apache.hadoop.mapred.child.main(child。java:249)原因:org.apache.thrift.tapplicationexception:在org.apache.thrift.tapplicationexception.read(tapplicationexception)处理get_range_片时发生内部错误。java:108)在org.apache.cassandra.thrift.cassandra$client.recv\u get\u range\u slices(cassandra。java:754)在org.apache.cassandra.thrift.cassandra$client.get\u range\u slices(cassandra。java:734)在org.apache.cassandra.hadoop.columnfamilyrecordreader$roweiterator.maybeinit(columnfamilyrecordreader)。java:289) ... 还有17个
有办法吗?我可以按要求出示Pig的剧本。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题