Hi,

Flink hbase connector官网有的[1],1.10以前的包名是flink-hbase, 
1.11后社区统一了所有connector的包名,包名为flink-connector-hbase[1],1.11最近快发布了,你的报错看起来是缺少了一些类,可以参考下hbase
 connector的依赖[2]。

Best,
Leonard Xu
[1] 
https://ci.apache.org/projects/flink/flink-docs-master/dev/table/connect.html#hbase-connector
 
<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
 
<https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-hbase/pom.xml>
> 在 2020年6月5日,09:31,liunaihua521 <[email protected]> 写道:
> 
> hi,
>    sink是自己的,我还没发现flink有原生的hbase的sink,正在研究.
> 
> 
> 在2020年6月5日 09:06,[email protected]<[email protected]> 写道:
> Sink 是自己的还是官方的。
> 
> 
> 
> [email protected]
> 
> 发件人: liunaihua521
> 发送时间: 2020-06-05 00:27
> 收件人: [email protected]
> 主题: flink整合hbase
> hi
> 咨询下,想用flink1.10整合hbase,请问一下hadoop,hbase都需要什么版本?有哪位跑通过,可否提供下配置文件,我在本地测试,所有集群都正常启动,提交任务(flink读写hbase)总是报错,找不到某些类,是否跟版本有问题?
> 提前谢谢了!
> 
> | |
> liunaihua521
> |
> |
> 邮箱:[email protected]
> |
> 
> 签名由 网易邮箱大师 定制

回复