flink1.11.2 一直不入hbase问题

Wed, 25 Nov 2020 22:05:51 -0800 

Hi，ALL：
我这边测试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<aaa bigint>,
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如下：


发送自 Windows 10 版邮件应用

回复