hadoop - 如何在 hadoop 2.2.0 上集成 pig 和 cassandra?

标签 hadoop cassandra apache-pig

我收到以下错误,当我要使用 pig 将数据插入 cassandra 时,

错误 org.apache.pig.tools.grunt.Grunt - 错误 2998:未处理的内部错误。
找到接口(interface) org.apache.hadoop.mapreduce.JobContext,但预期类

我的 pig 脚本是,

存储插入格式 INTO
'cql://cql3ks/simple_table1?output_query=UPDATE+cql3ks.simple_table1+set+b+%3D+%3F'
使用 CqlStorage;

最佳答案

检查此链接https://pig.apache.org/docs/r0.12.0/start.html#req对于 hadoop 支持的 pig 版本。

似乎对于 pig 0.12.0 -> Hadoop 0.20.2、020.203、020.204、0.20.205、1.0.0、1.0.1 或 0.23.0、0.23.1

对于 pig 0.14.x -> Hadoop 0.23.X、1.X 或 2.X https://pig.apache.org/docs/r0.14.0/start.html#req

关于hadoop - 如何在 hadoop 2.2.0 上集成 pig 和 cassandra?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/40583387/

相关文章:

hadoop - pig 镀金 : filtering records based on values in bag

hadoop - Spark/Hadoop 为大型 LZO 文件抛出异常

hadoop - Apache Sqoop增量导入

hadoop - 文件或目录如何存储在 hadoop hdfs 中

hadoop - Pig 的 UDF 错误 - 无法使用导入解决

hadoop - 在Pig中生成有序文件时出现问题

java - Hadoop结果困惑

java - Cassandra java驱动程序连接错误

node.js - Cassandra手动分页: exposing pageState to client (in nodeJS)

java - 使用 Astyanax 创建的键空间对 cqlsh 不可见