PIG Cassandra ERROR 2118 无法获取输入拆分

PIG Cassandra ERROR 2118 Could not get input splits

我开始尝试使用 datastax 中的本教程进行简单的 pig+cassandra 集成:http://docs.datastax.com/en/datastax_enterprise/4.5/datastax_enterprise/ana/anaPigExRel.html

但是当我尝试将结果存储到 cql 中时,出现此错误:

Message: org.apache.pig.backend.executionengine.ExecException: ERROR 2118: Could not get input splits at org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigInputFormat.getSplits(PigInputFormat.java:279)

有什么想法吗?我在这里阅读了一些答案,指的是将我的 PIG_PARTITIONER 更改为 Murmur3Partitioner

我已经这样做了,而且仍然发生。是配置问题吗?

export PIG_PARTITIONER=org.apache.cassandra.dht.Murmur3Partitioner

我发现这样做之后:

export PIG_PARTITIONER=org.apache.cassandra.dht.Murmur3Partitioner

我需要从那个特定的控制台执行 source ~/.bashrc 和 pig。

虽然我又遇到了一个错误,但我认为这个案例已经解决了。