hi : 你是如何定义的source 表 和sink 表的吗? 能贴出来具体的建表语句吗?
wukon...@foxmail.com 发件人: xiaohui zhang 发送时间: 2021-09-09 17:19 收件人: user-zh 主题: hbase 列设置TTL过期后,flink不能再写入数据 Flink:1.12.1 Flink-connector: 2.2 Hbase: 2.1.0 + CDH6.3.2 现象:如果hbase列族设置了TTL,当某一rowkey写入数据,到达过期时间,列族会被hbase标记为删除。 后续如果有相同key的数据过来,flink无法将数据写入到hbase中,查询hbase中列族一直为空。 执行的过程大致如下: 创建Hbase表,test, 两个列族 cf1 , TTL 60, cf2, TTL 120, 数据TTL分别为1分钟,2分钟。 使用sql写入数据至表中 insert into test select 'rowkey', ROW('123'), ROW('456') from sometable; 过一分钟后,通过hbase 查询,可发现无cf1数据,两分钟后该rowkey无对应数据。 此时再通过flink写入数据,发现无法写入,且flink不报错 请问这个情况是Bug,还是Hbase的问题呢?