cassandra - Spark 上 Amplab 鲨鱼的蜂巢内部错误

Question

请...需要帮助。

我已按照步骤构建 spark 和 Shark 以从 hdfs/cassandra 查询数据。我在 hdfs 上有一个 cassandra 集群，可以成功查看数据库。但是不能运行select语句

鲨鱼>从calls_flow限制1中选择*；失败：Hive 内部错误：java.lang.RuntimeException（java.lang.ClassNotFoundException：org.apache.hadoop.hive.cassandra.input.cql.HiveCqlInputFormat）

帮助将不胜感激。

谢谢

环境：cassandra 2.0.8、spark-0.9.0、shark-0.9.0

Answer 1

请确保将 cassandra jar 和 cassandra-hive 驱动程序/InputFormat jar 复制到所有集群机器上的 Shark lib 目录中。