flink1.11.2 一直不入hbase问题
我这边测试flink入hbase发现一直入不了hbase，也没有报错。我的具体环境如下：
Hbase版本1.1.2with hdp2.6.5
Hadoop版本2.7.3
Flink版本1.11.2
Hbasesink：
create table f_volteics_gm_all_h_hbase (
msisdn string,
INFO ROW
,
PRIMARY KEY (msisdn) NOT ENFORCED
) WITH (
'connector' = 'hbase-1.4.3',
'table-name' = 'f_volteics_gm_all_h',
'zookeeper.quorum' = '192.168.6.200:2181',
'sink.buffer-flush.max-size'='0',
'sink.buffer-flush.max-rows'='0'
处理逻辑从kafka读数据，写入hbase。如下：
我将我的程序打成jar包，在yarn上运行。结果没有报错，但一直没有数据入hbase。从监控页面上看bytes sent一直为0如下：
*来自志愿者整理的flink邮件归档
写回答
-
Flink 1.11.x 版本hbase的 identifier 都是 hbase-1.4, 不是 hbase-1.4.3, 应该会报错才对，可以确认下日志里也没有报错吗？ *来自志愿者整理的flink邮件归档
2021-12-06 14:09:15赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
