版本说明: 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邮件归档
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邮件归档
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。