开发者社区> 问答> 正文

flink1.10整合hbase测试一直报错怎么办?

版本说明: flink版本1.10 HBase版本2.2.4 ZK版本3.6.1 Hadoop版本2.10.0

程序说明:

程序是简单的实现RichSourceFunction和RichSinkFunction,读取和写入hbase,程序打包后上传standalone模式的集群.

报错说明: 提交任务后,总是报如下错误(附件附文本): <1B135BA0-EF16-482E-9388-BB058AB2C06C.png> 或者 <0BC55A5B-26B0-4BD5-A3DF-33985EDCE3E7.png>

尝试如下: 尝试一: flink的lib下有如下jar包: <44DE6BF1-09DA-44F5-B0A8-704B3539B675.png> 提交的jar包中发现没有下面连个类 执行后报错

尝试二: 将guava-11.0.2.jar包移动到hadoop的lib下,再次执行依然报错

尝试结果: 反复尝试都一致报错,求大神们指点,再此先谢谢了!

*来自志愿者整理的flink邮件归档

展开
收起
游客nnqbtnagn7h6s 2021-12-06 20:31:36 1145 0
1 条回答
写回答
取消 提交回答
  • Flink hbase connector官网有的[1],1.10以前的包名是flink-hbase, 1.11后社区统一了所有connector的包名,包名为flink-connector-hbase[1],1.11最近快发布了,你的报错看起来是缺少了一些类,可以参考下hbase connector的依赖[2]。

    [1] https://ci.apache.org/projects/flink/flink-docs-master/dev/table/connect.html#hbase-connector

    [2] https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-hbase/pom.xml

    *来自志愿者整理的flink邮件归档

    2021-12-06 21:52:09
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
大数据时代的存储 ——HBase的实践与探索 立即下载
Hbase在滴滴出行的应用场景和最佳实践 立即下载
阿里云HBase主备双活 立即下载