hadoop - 错误1070:使用导入无法解析CqlStorage:

Question

我试图在本地模式下在 pig 上运行此脚本:

test = LOAD 'cql://phoenix/simple_table/' USING CqlStorage; 

但是我遇到以下错误，

> 2016-05-10 18:28:48,249 [main] ERROR org.apache.pig.tools.grunt.Grunt
> - ERROR 1070: Could not resolve CqlStorage using imports: [, java.lang., org.apache.pig.builtin., org.apache.pig.impl.builtin.]
> Details at logfile: /home/hduser/pig_1462885029564.log

我正在使用hadoop 2.2.0，cassandra 1.2.4和pig 0.12.0。

我的bash文件是

export JAVA_HOME=/usr/lib/jvm/java-7-oracle
export PIG_HOME=/home/hduser/pig-0.12.0
export PIG_CONF_DIR=/home/hduser/pig-0.12.0/conf
export PIG_CLASSPATH=/home/hduser/apache-cassandra-1.2.4-src/lib/libthrift-0.7.0.jar
export PIG_INITIAL_ADDRESS=localhost;
export PIG_RPC_PORT=9160;
export PIG_PARTITIONER=org.apache.cassandra.dht.Murmur3Partitioner;

然后在Pig上运行此命令，

register '/home/hduser/apache-cassandra-1.2.4-src/build/apache-cassandra-1.2.4-SNAPSHOT.jar'
define CqlStorage org.apache.cassandra.hadoop.pig.CqlStorage();

但是我遇到了同样的错误，这是什么问题？

Answer 1

看起来您的类路径中没有cassandra jar文件。该类包含在分发中。

这是一个教程:http://saugereau.github.io/blog/2015/03/cassandra-pig/