hadoop - 运行 Cassandra + Pig 时出错

标签 hadoop cassandra apache-pig cassandra-2.0

我正在使用 cassandra/example/pig/bin/pig_cassandra 脚本在 Cassandra 上运行 Pig 脚本。 我在执行 rows = LOAD 'cassandra://schema1/users' USING org.apache.cassandra.hadoop.pig.CassandraStorage();

时遇到错误

错误: 错误 org.apache.pig.tools.grunt.Grunt - 错误 1069:解析类 org.apache.cassandra.hadoop.pig.CassandraStorage 的类版本号时出现问题

我在 mac os x 10.9 上运行 cassandra 2.0.3、pig 0.12.0 和 java 7

.bash_profile contains 
export PIG_HOME=~/pig-0.12.0-src
export PIG_CONF_DIR=~/hadoop-1.0.4/conf
export PIG_INITIAL_ADDRESS=localhost
export PIG_RPC_PORT=9160
export PIG_PARTITIONER=org.apache.cassandra.dht.Murmur3Partitioner

请指导我解决这个问题。预先感谢您的帮助。

最佳答案

您可以尝试如下使用 CqlStorage 吗?

rows = 使用 CqlStorage() 加载“cql://schema1/users”;

关于hadoop - 运行 Cassandra + Pig 时出错,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/20464504/

相关文章:

scala - 将RDD保存到HDFS时出错

java - Maven项目生成失败

python - 如何使用 cassandra-driver for python 将 map 类型插入 cassandra

java - Cassandra:如何设置客户端到节点的加密?

cassandra - 稳定加载程序。错误 : could not achieve replication factor 2 (found 1 replicas only), 检查您的 key 空间复制设置

hadoop - 了解 mapper 和 reducer 的用法

hadoop - 用avro模式编写时如何在拉丁 pig 中创建复杂记录

hadoop - yarn 和 --archives 选项上的 Spark

java - Mahout 0.9 CVB文档主题映射错误

hadoop - pig 皮过滤内袋