我收到以下错误,当我要使用 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/